org.codehaus.activemq.store.jdbc
Class JDBCTopicMessageStore

java.lang.Object
  extended byorg.codehaus.activemq.store.jdbc.JDBCMessageStore
      extended byorg.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 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.store.jdbc.JDBCMessageStore
adapter, destinationName, persistenceAdapter, sequenceGenerator, wireFormat
 
Constructor Summary
JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, org.codehaus.activemq.io.WireFormat wireFormat, String destinationName)
           
 
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 org.codehaus.activemq.store.jdbc.JDBCMessageStore
addMessage, getMessage, recover, removeAllMessages, removeMessage, start, stop
 
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
 

Constructor Detail

JDBCTopicMessageStore

public JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
                             JDBCAdapter adapter,
                             org.codehaus.activemq.io.WireFormat wireFormat,
                             String destinationName)
Method Detail

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.