org.codehaus.activemq.store.bdb
Class BDbTopicMessageStore

java.lang.Object
  extended byorg.codehaus.activemq.store.bdb.BDbMessageStore
      extended byorg.codehaus.activemq.store.bdb.BDbTopicMessageStore
All Implemented Interfaces:
org.codehaus.activemq.store.MessageStore, org.codehaus.activemq.service.Service, org.codehaus.activemq.store.TopicMessageStore

public class BDbTopicMessageStore
extends BDbMessageStore
implements org.codehaus.activemq.store.TopicMessageStore

Version:
$Revision: 1.2 $

Constructor Summary
BDbTopicMessageStore(com.sleepycat.je.Database database, com.sleepycat.je.SecondaryDatabase secondaryDatabase, com.sleepycat.je.SecondaryConfig secondaryConfig, SequenceNumberCreator sequenceNumberCreator, org.codehaus.activemq.io.WireFormat wireFormat, com.sleepycat.je.Database subscriptionDatabase)
           
 
Method Summary
 void decrementMessageCountAndMaybeDelete(org.codehaus.activemq.service.MessageIdentity messageIdentity, org.codehaus.activemq.message.MessageAck ack)
           
protected  com.sleepycat.je.DatabaseEntry doSetLastAcknowledgedMessageIdentity(org.codehaus.activemq.service.Subscription subscription, org.codehaus.activemq.service.MessageIdentity messageIdentity)
           
protected  com.sleepycat.je.DatabaseEntry getLastAcknowledgedMessageID(org.codehaus.activemq.service.Subscription subscription, org.codehaus.activemq.service.MessageIdentity lastDispatchedMessage)
           
 org.codehaus.activemq.service.MessageIdentity getLastestMessageIdentity()
           
 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.bdb.BDbMessageStore
addMessage, asBytes, asBytes, checkClosed, createKey, extractMessage, extractString, findSequenceNumber, getContainer, getCursorConfig, getDatabase, getMessage, getSecondaryDatabase, getSequenceNumberKey, 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

BDbTopicMessageStore

public BDbTopicMessageStore(com.sleepycat.je.Database database,
                            com.sleepycat.je.SecondaryDatabase secondaryDatabase,
                            com.sleepycat.je.SecondaryConfig secondaryConfig,
                            SequenceNumberCreator sequenceNumberCreator,
                            org.codehaus.activemq.io.WireFormat wireFormat,
                            com.sleepycat.je.Database subscriptionDatabase)
Method Detail

incrementMessageCount

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

decrementMessageCountAndMaybeDelete

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

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 BDbMessageStore
Throws:
JMSException

getLastAcknowledgedMessageID

protected com.sleepycat.je.DatabaseEntry getLastAcknowledgedMessageID(org.codehaus.activemq.service.Subscription subscription,
                                                                      org.codehaus.activemq.service.MessageIdentity lastDispatchedMessage)
                                                               throws com.sleepycat.je.DatabaseException
Throws:
com.sleepycat.je.DatabaseException

doSetLastAcknowledgedMessageIdentity

protected com.sleepycat.je.DatabaseEntry doSetLastAcknowledgedMessageIdentity(org.codehaus.activemq.service.Subscription subscription,
                                                                              org.codehaus.activemq.service.MessageIdentity messageIdentity)
                                                                       throws com.sleepycat.je.DatabaseException
Throws:
com.sleepycat.je.DatabaseException


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