|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ReferenceStore
Represents a message store which is used by the persistent implementations
Nested Class Summary | |
---|---|
static class |
ReferenceStore.ReferenceData
|
Method Summary | |
---|---|
boolean |
addMessageReference(ConnectionContext context,
MessageId messageId,
ReferenceStore.ReferenceData data)
Adds a message reference to the message store |
ReferenceStore.ReferenceData |
getMessageReference(MessageId identity)
Looks up a message using either the String messageID or the messageNumber. |
java.util.concurrent.locks.Lock |
getStoreLock()
|
void |
setBatch(MessageId startAfter)
allow caching cursors to set the current batch offset when cache is exhausted |
boolean |
supportsExternalBatchControl()
|
Methods inherited from interface org.apache.activemq.store.MessageStore |
---|
addMessage, addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getMessage, getMessageCount, isEmpty, isPrioritizedMessages, recover, recoverNextMessages, removeAllMessages, removeAsyncMessage, removeMessage, resetBatching, setMemoryUsage, setPrioritizedMessages |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
boolean addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data) throws java.io.IOException
java.io.IOException
ReferenceStore.ReferenceData getMessageReference(MessageId identity) throws java.io.IOException
java.io.IOException
boolean supportsExternalBatchControl()
void setBatch(MessageId startAfter)
MessageStore
setBatch
in interface MessageStore
java.util.concurrent.locks.Lock getStoreLock()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |