public abstract class AbstractMessageStore extends java.lang.Object implements MessageStore
Modifier and Type | Field and Description |
---|---|
protected ActiveMQDestination |
destination |
static java.util.concurrent.FutureTask<java.lang.Object> |
FUTURE |
protected boolean |
prioritizedMessages |
Constructor and Description |
---|
AbstractMessageStore(ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<java.lang.Object> |
asyncAddQueueMessage(ConnectionContext context,
Message message)
Adds a message to the message store
|
java.util.concurrent.Future<java.lang.Object> |
asyncAddTopicMessage(ConnectionContext context,
Message message)
Adds a message to the message store
|
void |
dispose(ConnectionContext context) |
ActiveMQDestination |
getDestination()
The destination that the message store is holding messages for.
|
boolean |
isEmpty()
flag to indicate if the store is empty
|
boolean |
isPrioritizedMessages() |
void |
removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
setBatch(MessageId messageId)
allow caching cursors to set the current batch offset when cache is exhausted
|
void |
setMemoryUsage(MemoryUsage memoryUsage) |
void |
setPrioritizedMessages(boolean prioritizedMessages)
A hint to the store to try recover messages according to priority
|
void |
start() |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMessage, getMessage, getMessageCount, recover, recoverNextMessages, removeAllMessages, removeMessage, resetBatching
public static final java.util.concurrent.FutureTask<java.lang.Object> FUTURE
protected final ActiveMQDestination destination
protected boolean prioritizedMessages
public AbstractMessageStore(ActiveMQDestination destination)
public void dispose(ConnectionContext context)
dispose
in interface MessageStore
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public ActiveMQDestination getDestination()
MessageStore
getDestination
in interface MessageStore
public void setMemoryUsage(MemoryUsage memoryUsage)
setMemoryUsage
in interface MessageStore
memoryUsage
- The SystemUsage that is controlling the
destination's memory usage.public void setBatch(MessageId messageId) throws java.io.IOException, java.lang.Exception
MessageStore
setBatch
in interface MessageStore
java.lang.Exception
java.io.IOException
public boolean isEmpty() throws java.lang.Exception
isEmpty
in interface MessageStore
java.lang.Exception
public void setPrioritizedMessages(boolean prioritizedMessages)
MessageStore
setPrioritizedMessages
in interface MessageStore
public boolean isPrioritizedMessages()
isPrioritizedMessages
in interface MessageStore
public java.util.concurrent.Future<java.lang.Object> asyncAddQueueMessage(ConnectionContext context, Message message) throws java.io.IOException
MessageStore
asyncAddQueueMessage
in interface MessageStore
context
- contextjava.io.IOException
public java.util.concurrent.Future<java.lang.Object> asyncAddTopicMessage(ConnectionContext context, Message message) throws java.io.IOException
MessageStore
asyncAddTopicMessage
in interface MessageStore
context
- contextjava.io.IOException
public void removeAsyncMessage(ConnectionContext context, MessageAck ack) throws java.io.IOException
removeAsyncMessage
in interface MessageStore
java.io.IOException
Copyright © 2005-2012. All Rights Reserved.