|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.store.jdbm.JdbmMessageStore
Constructor Summary | |
JdbmMessageStore(jdbm.btree.BTree messageTable,
jdbm.btree.BTree orderedIndex)
|
Method Summary | |
MessageIdentity |
addMessage(ActiveMQMessage message)
Adds a message to the message store |
protected JMSException |
closeTable(jdbm.btree.BTree table,
JMSException firstException)
|
protected Object |
findSequenceNumber(String messageID)
Finds the sequence number for the given messageID |
protected MessageContainer |
getContainer()
|
protected long |
getLastSequenceNumber()
|
ActiveMQMessage |
getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
protected ActiveMQMessage |
getMessageBySequenceNumber(Long sequenceNumber)
Looks up the message using the given sequence number |
protected jdbm.btree.BTree |
getMessageTable()
|
protected jdbm.btree.BTree |
getOrderedIndex()
|
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 JdbmMessageStore(jdbm.btree.BTree messageTable, jdbm.btree.BTree orderedIndex)
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 MessageContainer getContainer()
protected long getLastSequenceNumber()
protected jdbm.btree.BTree getMessageTable() throws AlreadyClosedException
AlreadyClosedException
protected jdbm.btree.BTree getOrderedIndex() throws AlreadyClosedException
AlreadyClosedException
protected ActiveMQMessage getMessageBySequenceNumber(Long sequenceNumber) throws IOException, JMSException
IOException
JMSException
protected Object findSequenceNumber(String messageID) throws IOException, AlreadyClosedException
messageID
-
IOException
AlreadyClosedException
protected JMSException closeTable(jdbm.btree.BTree table, JMSException firstException)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |