|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.store.jdbc.JDBCMessageStore
org.activemq.store.jdbc.JDBCTopicMessageStore
Field Summary |
Fields inherited from class org.activemq.store.jdbc.JDBCMessageStore |
adapter, destinationName, persistenceAdapter, sequenceGenerator, wireFormat |
Constructor Summary | |
JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
String destinationName)
|
Method Summary | |
void |
decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity)
Decrement the reference count of this message ID and if there are no more references then delete the message from persistent store (or maybe archive it off somewhere) |
void |
deleteSubscription(String subscription)
|
MessageIdentity |
getLastestMessageIdentity()
Returns the last message identity that was delivered on this container which can then be used as a checkpoint so that when new durable consumers start, we know where to checkpoint their subscriptions. |
SubscriberEntry |
getSubscriberEntry(ConsumerInfo info)
Finds the subscriber entry for the given consumer info |
void |
incrementMessageCount(MessageIdentity messageId)
Increments the reference count of the message ID as its been dispatched to another subscriber. |
void |
recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
For the new subcription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription. |
void |
setLastAcknowledgedMessageIdentity(String subscription,
MessageIdentity messageIdentity)
Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint |
void |
setSubscriberEntry(ConsumerInfo info,
SubscriberEntry subscriberEntry)
Inserts or updates the subscriber info due to a subscription change |
Methods inherited from class org.activemq.store.jdbc.JDBCMessageStore |
addMessage, getMessage, getMessageSequenceId, 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.activemq.store.MessageStore |
addMessage, getMessage, recover, removeAllMessages, removeMessage |
Methods inherited from interface org.activemq.service.Service |
start, stop |
Constructor Detail |
public JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, WireFormat wireFormat, String destinationName)
Method Detail |
public void setLastAcknowledgedMessageIdentity(String subscription, MessageIdentity messageIdentity) throws JMSException
TopicMessageStore
setLastAcknowledgedMessageIdentity
in interface TopicMessageStore
messageIdentity
-
JMSException
public MessageIdentity getLastestMessageIdentity() throws JMSException
TopicMessageStore
getLastestMessageIdentity
in interface TopicMessageStore
JMSException
TopicMessageStore.getLastestMessageIdentity()
public void recoverSubscription(String subscriptionId, MessageIdentity lastDispatchedMessage, RecoveryListener listener) throws JMSException
TopicMessageStore
recoverSubscription
in interface TopicMessageStore
lastDispatchedMessage
-
JMSException
public void setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry) throws JMSException
TopicMessageStore
setSubscriberEntry
in interface TopicMessageStore
info
- subscriberEntry
-
JMSException
TopicMessageStore.setSubscriberEntry(org.activemq.message.ConsumerInfo, org.activemq.service.SubscriberEntry)
public SubscriberEntry getSubscriberEntry(ConsumerInfo info) throws JMSException
TopicMessageStore
getSubscriberEntry
in interface TopicMessageStore
info
-
JMSException
TopicMessageStore.getSubscriberEntry(org.activemq.message.ConsumerInfo)
public void deleteSubscription(String subscription) throws JMSException
deleteSubscription
in interface TopicMessageStore
JMSException
public void incrementMessageCount(MessageIdentity messageId) throws JMSException
TopicMessageStore
incrementMessageCount
in interface TopicMessageStore
messageId
-
JMSException
public void decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity) throws JMSException
TopicMessageStore
decrementMessageCountAndMaybeDelete
in interface TopicMessageStore
messageIdentity
-
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |