org.codehaus.activemq.store.jdbm
Class JdbmTopicMessageStore

java.lang.Object
  extended byorg.codehaus.activemq.store.jdbm.JdbmMessageStore
      extended byorg.codehaus.activemq.store.jdbm.JdbmTopicMessageStore
All Implemented Interfaces:
org.codehaus.activemq.store.MessageStore, org.codehaus.activemq.service.Service, org.codehaus.activemq.store.TopicMessageStore

public class JdbmTopicMessageStore
extends JdbmMessageStore
implements org.codehaus.activemq.store.TopicMessageStore

Version:
$Revision: 1.1 $

Constructor Summary
JdbmTopicMessageStore(jdbm.btree.BTree messageTable, jdbm.btree.BTree orderedIndex, jdbm.btree.BTree ackDatabase, jdbm.btree.BTree subscriberDetails, jdbm.btree.BTree messageCounts)
           
 
Method Summary
 void decrementMessageCountAndMaybeDelete(org.codehaus.activemq.service.MessageIdentity messageIdentity, org.codehaus.activemq.message.MessageAck ack)
           
protected  jdbm.btree.BTree getAckDatabase()
           
protected  org.codehaus.activemq.service.MessageIdentity getLastAcknowledgedMessageIdentity(org.codehaus.activemq.service.Subscription subscription)
           
 org.codehaus.activemq.service.MessageIdentity getLastestMessageIdentity()
           
protected  jdbm.btree.BTree getMessageCounts()
           
 org.codehaus.activemq.service.SubscriberEntry getSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo info)
           
 void incrementMessageCount(org.codehaus.activemq.service.MessageIdentity messageId)
           
 void recoverSubscription(org.codehaus.activemq.service.Subscription subscription, org.codehaus.activemq.service.MessageIdentity lastDispatchedMessage)
           
 void setLastAcknowledgedMessageIdentity(org.codehaus.activemq.service.Subscription subscription, org.codehaus.activemq.service.MessageIdentity messageIdentity)
           
 void setSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo info, org.codehaus.activemq.service.SubscriberEntry subscriberEntry)
           
 void stop()
           
 
Methods inherited from class org.codehaus.activemq.store.jdbm.JdbmMessageStore
addMessage, closeTable, findSequenceNumber, getContainer, getLastSequenceNumber, getMessage, getMessageBySequenceNumber, getMessageTable, getOrderedIndex, recover, removeAllMessages, removeMessage, setMessageContainer, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.codehaus.activemq.store.TopicMessageStore
setMessageContainer
 
Methods inherited from interface org.codehaus.activemq.store.MessageStore
addMessage, getMessage, recover, removeAllMessages, removeMessage
 
Methods inherited from interface org.codehaus.activemq.service.Service
start
 

Constructor Detail

JdbmTopicMessageStore

public JdbmTopicMessageStore(jdbm.btree.BTree messageTable,
                             jdbm.btree.BTree orderedIndex,
                             jdbm.btree.BTree ackDatabase,
                             jdbm.btree.BTree subscriberDetails,
                             jdbm.btree.BTree messageCounts)
Method Detail

incrementMessageCount

public void incrementMessageCount(org.codehaus.activemq.service.MessageIdentity messageId)
                           throws JMSException
Specified by:
incrementMessageCount in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

decrementMessageCountAndMaybeDelete

public void decrementMessageCountAndMaybeDelete(org.codehaus.activemq.service.MessageIdentity messageIdentity,
                                                org.codehaus.activemq.message.MessageAck ack)
                                         throws JMSException
Specified by:
decrementMessageCountAndMaybeDelete in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

setLastAcknowledgedMessageIdentity

public void setLastAcknowledgedMessageIdentity(org.codehaus.activemq.service.Subscription subscription,
                                               org.codehaus.activemq.service.MessageIdentity messageIdentity)
                                        throws JMSException
Specified by:
setLastAcknowledgedMessageIdentity in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

recoverSubscription

public void recoverSubscription(org.codehaus.activemq.service.Subscription subscription,
                                org.codehaus.activemq.service.MessageIdentity lastDispatchedMessage)
                         throws JMSException
Specified by:
recoverSubscription in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

getLastestMessageIdentity

public org.codehaus.activemq.service.MessageIdentity getLastestMessageIdentity()
                                                                        throws JMSException
Specified by:
getLastestMessageIdentity in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

getSubscriberEntry

public org.codehaus.activemq.service.SubscriberEntry getSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo info)
                                                                 throws JMSException
Specified by:
getSubscriberEntry in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

setSubscriberEntry

public void setSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo info,
                               org.codehaus.activemq.service.SubscriberEntry subscriberEntry)
                        throws JMSException
Specified by:
setSubscriberEntry in interface org.codehaus.activemq.store.TopicMessageStore
Throws:
JMSException

stop

public void stop()
          throws JMSException
Specified by:
stop in interface org.codehaus.activemq.service.Service
Overrides:
stop in class JdbmMessageStore
Throws:
JMSException

getMessageCounts

protected jdbm.btree.BTree getMessageCounts()
                                     throws org.codehaus.activemq.AlreadyClosedException
Throws:
org.codehaus.activemq.AlreadyClosedException

getAckDatabase

protected jdbm.btree.BTree getAckDatabase()
                                   throws org.codehaus.activemq.AlreadyClosedException
Throws:
org.codehaus.activemq.AlreadyClosedException

getLastAcknowledgedMessageIdentity

protected org.codehaus.activemq.service.MessageIdentity getLastAcknowledgedMessageIdentity(org.codehaus.activemq.service.Subscription subscription)
                                                                                    throws IOException,
                                                                                           org.codehaus.activemq.AlreadyClosedException
Throws:
IOException
org.codehaus.activemq.AlreadyClosedException


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.