|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.store.bdb.BDbMessageStore
Constructor Summary | |
BDbMessageStore(com.sleepycat.je.Database database,
com.sleepycat.je.SecondaryDatabase secondaryDatabase,
com.sleepycat.je.SecondaryConfig secondaryConfig,
SequenceNumberCreator sequenceNumberCreator,
WireFormat wireFormat)
|
Method Summary | |
MessageIdentity |
addMessage(ActiveMQMessage message)
Adds a message to the message store |
protected byte[] |
asBytes(ActiveMQMessage message)
|
protected byte[] |
asBytes(String messageID)
|
protected void |
checkClosed()
|
protected com.sleepycat.je.DatabaseEntry |
createKey(String messageID)
|
protected ActiveMQMessage |
extractMessage(com.sleepycat.je.DatabaseEntry value)
|
protected String |
extractString(com.sleepycat.je.DatabaseEntry entry)
|
protected com.sleepycat.je.DatabaseEntry |
findSequenceNumber(String messageID)
Iterates through from the start of the collection until the given message ID is found |
MessageContainer |
getContainer()
|
com.sleepycat.je.CursorConfig |
getCursorConfig()
|
protected com.sleepycat.je.Database |
getDatabase()
|
ActiveMQMessage |
getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
protected com.sleepycat.je.SecondaryDatabase |
getSecondaryDatabase()
|
protected com.sleepycat.je.DatabaseEntry |
getSequenceNumberKey(MessageIdentity identity)
Returns the sequence number key for the given message identity. |
void |
recover(QueueMessageContainer container)
Recover any messages to be delivered onto the dispatch queue. |
void |
removeMessage(MessageIdentity identity,
MessageAck ack)
|
void |
setMessageContainer(MessageContainer container)
|
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 BDbMessageStore(com.sleepycat.je.Database database, com.sleepycat.je.SecondaryDatabase secondaryDatabase, com.sleepycat.je.SecondaryConfig secondaryConfig, SequenceNumberCreator sequenceNumberCreator, WireFormat wireFormat)
Method Detail |
public void setMessageContainer(MessageContainer container)
public MessageIdentity addMessage(ActiveMQMessage message) throws JMSException
MessageStore
addMessage
in interface MessageStore
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 removeMessage(MessageIdentity identity, MessageAck ack) throws JMSException
removeMessage
in interface MessageStore
JMSException
public void recover(QueueMessageContainer container) throws JMSException
MessageStore
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
protected com.sleepycat.je.SecondaryDatabase getSecondaryDatabase()
protected com.sleepycat.je.Database getDatabase()
public com.sleepycat.je.CursorConfig getCursorConfig()
public MessageContainer getContainer()
protected void checkClosed() throws AlreadyClosedException
AlreadyClosedException
protected com.sleepycat.je.DatabaseEntry getSequenceNumberKey(MessageIdentity identity) throws com.sleepycat.je.DatabaseException
identity
-
com.sleepycat.je.DatabaseException
protected com.sleepycat.je.DatabaseEntry createKey(String messageID)
protected com.sleepycat.je.DatabaseEntry findSequenceNumber(String messageID) throws com.sleepycat.je.DatabaseException
messageID
-
com.sleepycat.je.DatabaseException
protected String extractString(com.sleepycat.je.DatabaseEntry entry)
protected ActiveMQMessage extractMessage(com.sleepycat.je.DatabaseEntry value) throws IOException
IOException
protected byte[] asBytes(ActiveMQMessage message) throws IOException, JMSException
IOException
JMSException
protected byte[] asBytes(String messageID)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |