public class AMQMessageStore extends AbstractMessageStore
Modifier and Type | Field and Description |
---|---|
protected TaskRunner |
asyncWriteTask |
protected CountDownLatch |
flushLatch |
protected Set<Location> |
inFlightTxLocations |
protected Location |
lastLocation |
protected Location |
lastWrittenLocation |
protected Lock |
lock |
protected AMQPersistenceAdapter |
peristenceAdapter |
protected ReferenceStore |
referenceStore |
protected AMQTransactionStore |
transactionStore |
protected TransactionTemplate |
transactionTemplate |
destination, FUTURE, prioritizedMessages
Constructor and Description |
---|
AMQMessageStore(AMQPersistenceAdapter adapter,
ReferenceStore referenceStore,
ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
addMessage(ConnectionContext context,
Message message)
Not synchronize since the Journal has better throughput if you increase the number of concurrent writes that it
is doing.
|
void |
addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
String messageRef) |
void |
dispose(ConnectionContext context) |
protected Location |
doAsyncWrite() |
void |
flush()
Waits till the lastest data has landed on the referenceStore
|
protected Location |
getLocation(MessageId messageId) |
Location |
getMark() |
Message |
getMessage(MessageId identity)
Looks up a message using either the String messageID or the
messageNumber.
|
int |
getMessageCount() |
String |
getMessageReference(MessageId identity) |
ReferenceStore |
getReferenceStore() |
void |
recover(MessageRecoveryListener listener)
Replays the referenceStore first as those messages are the oldest ones, then messages are replayed from the
transaction log and then the cache is updated.
|
void |
recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
removeAllMessages(ConnectionContext context)
Removes all the messages from the message store.
|
void |
removeMessage(ConnectionContext context,
MessageAck ack)
Removes a message from the message store.
|
boolean |
replayAddMessage(ConnectionContext context,
Message message,
Location location) |
boolean |
replayRemoveMessage(ConnectionContext context,
MessageAck messageAck) |
void |
resetBatching()
A hint to the Store to reset any batching state for the Destination
|
void |
setBatch(MessageId messageId)
allow caching cursors to set the current batch offset when cache is exhausted
|
void |
setMemoryUsage(MemoryUsage memoryUsage) |
void |
start() |
void |
stop() |
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, getDestination, isEmpty, isPrioritizedMessages, removeAsyncMessage, setPrioritizedMessages
protected final AMQPersistenceAdapter peristenceAdapter
protected final AMQTransactionStore transactionStore
protected final ReferenceStore referenceStore
protected final TransactionTemplate transactionTemplate
protected Location lastLocation
protected Location lastWrittenLocation
protected final TaskRunner asyncWriteTask
protected CountDownLatch flushLatch
protected final Lock lock
public AMQMessageStore(AMQPersistenceAdapter adapter, ReferenceStore referenceStore, ActiveMQDestination destination)
public void setMemoryUsage(MemoryUsage memoryUsage)
setMemoryUsage
in interface MessageStore
setMemoryUsage
in class AbstractMessageStore
memoryUsage
- The SystemUsage that is controlling the
destination's memory usage.public final void addMessage(ConnectionContext context, Message message) throws IOException
context
- contextIOException
public boolean replayAddMessage(ConnectionContext context, Message message, Location location)
public void removeMessage(ConnectionContext context, MessageAck ack) throws IOException
MessageStore
ack
- the ack request that cause the message to be removed. It
conatins the identity which contains the messageID of the
message that needs to be removed.IOException
public boolean replayRemoveMessage(ConnectionContext context, MessageAck messageAck)
public void flush() throws InterruptedIOException
InterruptedIOException
protected Location doAsyncWrite() throws IOException
IOException
public Message getMessage(MessageId identity) throws IOException
MessageStore
identity
- which contains either the messageID or the messageNumberIOException
protected Location getLocation(MessageId messageId) throws IOException
IOException
public void recover(MessageRecoveryListener listener) throws Exception
listener
- Exception
public void start() throws Exception
start
in interface Service
start
in class AbstractMessageStore
Exception
public void stop() throws Exception
stop
in interface Service
stop
in class AbstractMessageStore
Exception
public ReferenceStore getReferenceStore()
public void removeAllMessages(ConnectionContext context) throws IOException
MessageStore
IOException
MessageStore.removeAllMessages(ConnectionContext)
public void addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef) throws IOException
IOException
public String getMessageReference(MessageId identity) throws IOException
IOException
public int getMessageCount() throws IOException
IOException
MessageStore.getMessageCount()
public void recoverNextMessages(int maxReturned, MessageRecoveryListener listener) throws Exception
Exception
public void resetBatching()
MessageStore
public Location getMark()
public void dispose(ConnectionContext context)
dispose
in interface MessageStore
dispose
in class AbstractMessageStore
public void setBatch(MessageId messageId)
MessageStore
setBatch
in interface MessageStore
setBatch
in class AbstractMessageStore
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.