public interface ReferenceStore extends MessageStore
Modifier and Type | Interface and Description |
---|---|
static class |
ReferenceStore.ReferenceData |
Modifier and Type | Method and Description |
---|---|
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.
|
Lock |
getStoreLock() |
void |
setBatch(MessageId startAfter)
allow caching cursors to set the current batch offset when cache is exhausted
|
boolean |
supportsExternalBatchControl() |
addMessage, addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getMessage, getMessageCount, isEmpty, isPrioritizedMessages, recover, recoverNextMessages, removeAllMessages, removeAsyncMessage, removeMessage, resetBatching, setMemoryUsage, setPrioritizedMessages
boolean addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data) throws IOException
IOException
ReferenceStore.ReferenceData getMessageReference(MessageId identity) throws IOException
IOException
boolean supportsExternalBatchControl()
void setBatch(MessageId startAfter)
MessageStore
setBatch
in interface MessageStore
Lock getStoreLock()
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.