|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.store.ProxyTopicMessageStore
A simple proxy that delegates to another MessageStore.
Constructor Summary | |
ProxyTopicMessageStore(TopicMessageStore delegate)
|
Method Summary | |
void |
addMessage(ActiveMQMessage message)
Adds a message to the message store |
void |
decrementMessageCountAndMaybeDelete(MessageIdentity msgId)
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)
|
MessageStore |
getDelegate()
|
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. |
ActiveMQMessage |
getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
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 |
recover(RecoveryListener listener)
Recover any messages to be delivered. |
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 |
removeAllMessages()
Removes all the messages from the message store. |
void |
removeMessage(MessageAck ack)
Removes a message from the message store. |
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 |
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ProxyTopicMessageStore(TopicMessageStore delegate)
Method Detail |
public MessageStore getDelegate()
public void addMessage(ActiveMQMessage message) throws JMSException
MessageStore
addMessage
in interface MessageStore
JMSException
public ActiveMQMessage getMessage(MessageIdentity identity) throws JMSException
MessageStore
getMessage
in interface MessageStore
identity
- which contains either the messageID or the messageNumber
JMSException
public void recover(RecoveryListener listener) throws JMSException
MessageStore
recover
in interface MessageStore
listener
-
JMSException
public void removeAllMessages() throws JMSException
MessageStore
removeAllMessages
in interface MessageStore
JMSException
public void removeMessage(MessageAck ack) throws JMSException
MessageStore
removeMessage
in interface MessageStore
ack
- the ack request that cause the message to be removed. It conatins
the identity which contains the messageID of the message that needs to be removed.
JMSException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public void decrementMessageCountAndMaybeDelete(MessageIdentity msgId) throws JMSException
TopicMessageStore
decrementMessageCountAndMaybeDelete
in interface TopicMessageStore
msgId
-
JMSException
public MessageIdentity getLastestMessageIdentity() throws JMSException
TopicMessageStore
getLastestMessageIdentity
in interface TopicMessageStore
JMSException
public SubscriberEntry getSubscriberEntry(ConsumerInfo info) throws JMSException
TopicMessageStore
getSubscriberEntry
in interface TopicMessageStore
info
-
JMSException
public void incrementMessageCount(MessageIdentity messageId) throws JMSException
TopicMessageStore
incrementMessageCount
in interface TopicMessageStore
messageId
-
JMSException
public void setLastAcknowledgedMessageIdentity(String subscription, MessageIdentity messageIdentity) throws JMSException
TopicMessageStore
setLastAcknowledgedMessageIdentity
in interface TopicMessageStore
messageIdentity
-
JMSException
public void setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry) throws JMSException
TopicMessageStore
setSubscriberEntry
in interface TopicMessageStore
info
- subscriberEntry
-
JMSException
public void deleteSubscription(String subscription) throws JMSException
deleteSubscription
in interface TopicMessageStore
JMSException
public void recoverSubscription(String subscriptionId, MessageIdentity lastDispatchedMessage, RecoveryListener listener) throws JMSException
TopicMessageStore
recoverSubscription
in interface TopicMessageStore
lastDispatchedMessage
-
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |