org.codehaus.activemq.store.bdbn
Class BDbTopicMessageStore

java.lang.Object
  extended byorg.codehaus.activemq.store.bdbn.BDbMessageStore
      extended byorg.codehaus.activemq.store.bdbn.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

An implementation of TopicMessageStore using native C Berkeley DB

Version:
$Revision: 1.1 $

Constructor Summary
BDbTopicMessageStore()
           
 
Method Summary
 void decrementMessageCountAndMaybeDelete(org.codehaus.activemq.service.MessageIdentity messageIdentity, org.codehaus.activemq.message.MessageAck ack)
           
 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.bdbn.BDbMessageStore
addMessage, asBytes, asBytes, createKey, extractMessage, getMessage, 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()
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)
Specified by:
recoverSubscription in interface org.codehaus.activemq.store.TopicMessageStore

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


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