|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.store.journal.JournalMessageStore
A MessageStore that uses a Journal to store it's messages.
Constructor Summary | |
JournalMessageStore(JournalPersistenceAdapter adapter,
MessageStore checkpointStore,
String destinationName,
boolean sync)
|
Method Summary | |
MessageIdentity |
addMessage(ActiveMQMessage message)
Not synchronized since the Journal has better throughput if you increase the number of conncurrent writes that it is doing. |
RecordLocation |
checkpoint()
|
MessageStore |
getLongTermStore()
|
ActiveMQMessage |
getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
void |
recover(QueueMessageContainer container)
Replays the checkpointStore first as those messages are the oldest ones, then messages are replayed from the transaction log and then the cache is updated. |
void |
removeMessage(MessageIdentity identity,
MessageAck ack)
|
void |
setCacheMessageStore(CacheMessageStore store)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public JournalMessageStore(JournalPersistenceAdapter adapter, MessageStore checkpointStore, String destinationName, boolean sync)
Method Detail |
public MessageIdentity addMessage(ActiveMQMessage message) throws JMSException
addMessage
in interface MessageStore
JMSException
public void removeMessage(MessageIdentity identity, MessageAck ack) throws JMSException
removeMessage
in interface MessageStore
JMSException
public RecordLocation checkpoint() throws JMSException
JMSException
public ActiveMQMessage getMessage(MessageIdentity identity) throws JMSException
MessageStore
getMessage
in interface MessageStore
identity
- which contains either the messageID or the messageNumber
JMSException
public void recover(QueueMessageContainer container) throws JMSException
recover
in interface MessageStore
container
-
JMSException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public MessageStore getLongTermStore()
public void setCacheMessageStore(CacheMessageStore store)
setCacheMessageStore
in interface CacheMessageStoreAware
CacheMessageStoreAware.setCacheMessageStore(org.codehaus.activemq.store.cache.CacheMessageStore)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |