org.codehaus.activemq.store.jdbc
Class JDBCTopicMessageStore
java.lang.Object
org.codehaus.activemq.store.jdbc.JDBCMessageStore
org.codehaus.activemq.store.jdbc.JDBCTopicMessageStore
- All Implemented Interfaces:
- org.codehaus.activemq.store.MessageStore, org.codehaus.activemq.service.Service, org.codehaus.activemq.store.TopicMessageStore
- public class JDBCTopicMessageStore
- extends JDBCMessageStore
- implements org.codehaus.activemq.store.TopicMessageStore
- Version:
- $Revision: 1.2 $
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 |
setMessageContainer(org.codehaus.activemq.service.MessageContainer container)
|
void |
setSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo info,
org.codehaus.activemq.service.SubscriberEntry subscriberEntry)
|
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.MessageStore |
addMessage, getMessage, recover, removeAllMessages, removeMessage |
Methods inherited from interface org.codehaus.activemq.service.Service |
start, stop |
JDBCTopicMessageStore
public JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
org.codehaus.activemq.io.WireFormat wireFormat,
String destinationName)
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
getLastestMessageIdentity
public org.codehaus.activemq.service.MessageIdentity getLastestMessageIdentity()
throws JMSException
- Specified by:
getLastestMessageIdentity
in interface org.codehaus.activemq.store.TopicMessageStore
- Throws:
JMSException
- See Also:
TopicMessageStore.getLastestMessageIdentity()
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
- See Also:
TopicMessageStore.recoverSubscription(org.codehaus.activemq.service.Subscription, org.codehaus.activemq.service.MessageIdentity)
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
- See Also:
TopicMessageStore.setSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo, org.codehaus.activemq.service.SubscriberEntry)
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
- See Also:
TopicMessageStore.getSubscriberEntry(org.codehaus.activemq.message.ConsumerInfo)
setMessageContainer
public void setMessageContainer(org.codehaus.activemq.service.MessageContainer container)
- Specified by:
setMessageContainer
in interface org.codehaus.activemq.store.TopicMessageStore
- See Also:
TopicMessageStore.setMessageContainer(org.codehaus.activemq.service.MessageContainer)
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
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.