org.codehaus.activemq.store.bdbn
Class BDbTopicMessageStore
java.lang.Object
org.codehaus.activemq.store.bdbn.BDbMessageStore
org.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 $
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 |
BDbTopicMessageStore
public BDbTopicMessageStore()
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.