org.codehaus.activemq.store.jdbm
Class JdbmMessageStore
java.lang.Object
org.codehaus.activemq.store.jdbm.JdbmMessageStore
- All Implemented Interfaces:
- org.codehaus.activemq.store.MessageStore, org.codehaus.activemq.service.Service
- Direct Known Subclasses:
- JdbmTopicMessageStore
- public class JdbmMessageStore
- extends Object
- implements org.codehaus.activemq.store.MessageStore
- Version:
- $Revision: 1.2 $
Constructor Summary |
JdbmMessageStore(jdbm.btree.BTree messageTable,
jdbm.btree.BTree orderedIndex)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JdbmMessageStore
public JdbmMessageStore(jdbm.btree.BTree messageTable,
jdbm.btree.BTree orderedIndex)
setMessageContainer
public void setMessageContainer(org.codehaus.activemq.service.MessageContainer container)
addMessage
public org.codehaus.activemq.service.MessageIdentity addMessage(org.codehaus.activemq.message.ActiveMQMessage message)
throws JMSException
- Specified by:
addMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
getMessage
public org.codehaus.activemq.message.ActiveMQMessage getMessage(org.codehaus.activemq.service.MessageIdentity identity)
throws JMSException
- Specified by:
getMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
removeMessage
public void removeMessage(org.codehaus.activemq.service.MessageIdentity identity,
org.codehaus.activemq.message.MessageAck ack)
throws JMSException
- Specified by:
removeMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
recover
public void recover(org.codehaus.activemq.service.QueueMessageContainer container)
throws JMSException
- Specified by:
recover
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
start
public void start()
throws JMSException
- Specified by:
start
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Specified by:
stop
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
getContainer
protected org.codehaus.activemq.service.MessageContainer getContainer()
getLastSequenceNumber
protected long getLastSequenceNumber()
getMessageTable
protected jdbm.btree.BTree getMessageTable()
throws org.codehaus.activemq.AlreadyClosedException
- Throws:
org.codehaus.activemq.AlreadyClosedException
getOrderedIndex
protected jdbm.btree.BTree getOrderedIndex()
throws org.codehaus.activemq.AlreadyClosedException
- Throws:
org.codehaus.activemq.AlreadyClosedException
getMessageBySequenceNumber
protected org.codehaus.activemq.message.ActiveMQMessage getMessageBySequenceNumber(Long sequenceNumber)
throws IOException,
JMSException
- Looks up the message using the given sequence number
- Throws:
IOException
JMSException
findSequenceNumber
protected Object findSequenceNumber(String messageID)
throws IOException,
org.codehaus.activemq.AlreadyClosedException
- Finds the sequence number for the given messageID
- Parameters:
messageID
-
- Returns:
-
- Throws:
IOException
org.codehaus.activemq.AlreadyClosedException
closeTable
protected JMSException closeTable(jdbm.btree.BTree table,
JMSException firstException)
removeAllMessages
public void removeAllMessages()
throws JMSException
- Specified by:
removeAllMessages
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.