org.codehaus.activemq.store.jdbm
Class JdbmMessageStore

java.lang.Object
  extended byorg.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)
           
 
Method Summary
 org.codehaus.activemq.service.MessageIdentity addMessage(org.codehaus.activemq.message.ActiveMQMessage message)
           
protected  JMSException closeTable(jdbm.btree.BTree table, JMSException firstException)
           
protected  Object findSequenceNumber(String messageID)
          Finds the sequence number for the given messageID
protected  org.codehaus.activemq.service.MessageContainer getContainer()
           
protected  long getLastSequenceNumber()
           
 org.codehaus.activemq.message.ActiveMQMessage getMessage(org.codehaus.activemq.service.MessageIdentity identity)
           
protected  org.codehaus.activemq.message.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(org.codehaus.activemq.service.QueueMessageContainer container)
           
 void removeAllMessages()
           
 void removeMessage(org.codehaus.activemq.service.MessageIdentity identity, org.codehaus.activemq.message.MessageAck ack)
           
 void setMessageContainer(org.codehaus.activemq.service.MessageContainer container)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JdbmMessageStore

public JdbmMessageStore(jdbm.btree.BTree messageTable,
                        jdbm.btree.BTree orderedIndex)
Method Detail

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.