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