|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.store.AbstractMessageStore
public abstract class AbstractMessageStore
Field Summary | |
---|---|
protected ActiveMQDestination |
destination
|
static java.util.concurrent.FutureTask<java.lang.Object> |
FUTURE
|
protected boolean |
prioritizedMessages
|
Constructor Summary | |
---|---|
AbstractMessageStore(ActiveMQDestination destination)
|
Method Summary | |
---|---|
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()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.activemq.store.MessageStore |
---|
addMessage, getMessage, getMessageCount, recover, recoverNextMessages, removeAllMessages, removeMessage, resetBatching |
Field Detail |
---|
public static final java.util.concurrent.FutureTask<java.lang.Object> FUTURE
protected final ActiveMQDestination destination
protected boolean prioritizedMessages
Constructor Detail |
---|
public AbstractMessageStore(ActiveMQDestination destination)
Method Detail |
---|
public void dispose(ConnectionContext context)
dispose
in interface MessageStore
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
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
- context
java.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
- context
java.io.IOException
public void removeAsyncMessage(ConnectionContext context, MessageAck ack) throws java.io.IOException
removeAsyncMessage
in interface MessageStore
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |