org.codehaus.activemq.store.jdbm
Class JdbmTopicMessageStore
java.lang.Object
org.codehaus.activemq.store.jdbm.JdbmMessageStore
org.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)
|
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 |
JdbmTopicMessageStore
public JdbmTopicMessageStore(jdbm.btree.BTree messageTable,
jdbm.btree.BTree orderedIndex,
jdbm.btree.BTree ackDatabase,
jdbm.btree.BTree subscriberDetails,
jdbm.btree.BTree messageCounts)
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.