|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
A Topic based MessageContainer
Method Summary | |
void |
recoverSubscription(Subscription subscription)
A durable subscription has started so recovery any messages that are required. |
void |
setLastAcknowledgedMessageID(Subscription subscription,
MessageIdentity messageIdentity)
Sets the last acknowleged message ID for the given subscriber in this container so that if we shut down and recover we know where to start replaying messages from. |
void |
storeSubscription(ConsumerInfo info,
Subscription subscription)
Stores the persistence details in the database |
Methods inherited from interface org.codehaus.activemq.service.MessageContainer |
addMessage, containsMessage, delete, getDestinationName, getMessage, getMessageContainerAdmin, isDeadLetterQueue, registerMessageInterest, unregisterMessageInterest |
Methods inherited from interface org.codehaus.activemq.service.Service |
start, stop |
Method Detail |
public void setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity) throws JMSException
subscription
- messageIdentity
-
JMSException
public void recoverSubscription(Subscription subscription) throws JMSException
subscription
-
JMSException
public void storeSubscription(ConsumerInfo info, Subscription subscription) throws JMSException
info
- subscription
-
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |