Package com.arangodb.vst.internal

Class MessageStore

java.lang.Object

com.arangodb.vst.internal.MessageStore

public class MessageStore
extends Object

Author:

Mark Vollmary

Constructor Summary

Constructors

Constructor	Description
MessageStore()

Method Summary

Modifier and Type	Method	Description
void	cancel(long messageId)
void	clear(Exception e)
void	consume(Message message)
Message	get(long messageId)
boolean	isEmpty()
void	storeMessage(long messageId, FutureTask<Message> future)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageStore

public MessageStore()

Method Details

storeMessage

public void storeMessage(long messageId,
 FutureTask<Message> future)

consume

public void consume(Message message)

get

public Message get(long messageId)

cancel

public void cancel(long messageId)

clear

public void clear(Exception e)

isEmpty

public boolean isEmpty()