|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.impl.DurableTopicMessageContainer
public class DurableTopicMessageContainer
A default implementation of a Durable Topic based
MessageContainer
which acts as an adapter between the MessageContainerManager
requirements and those of the persistent TopicMessageStore
implementations.
Constructor Summary | |
---|---|
DurableTopicMessageContainer(DurableTopicMessageContainerManager manager,
TopicMessageStore messageStore,
String destinationName)
|
Method Summary | |
---|---|
void |
addMessage(ActiveMQMessage message)
Add an ActiveMQMessage to the message container |
boolean |
containsMessage(MessageIdentity messageIdentity)
Returns whether or not this container contains the given message identity which provides an optimisation over getMessage() where the message does not need to be loaded. |
void |
delete(MessageIdentity messageID,
MessageAck ack)
Delete a message - if no |
void |
deleteSubscription(String sub)
|
void |
empty()
Deletes all the messages that a container holds. |
String |
getDestinationName()
|
ActiveMQMessage |
getMessage(MessageIdentity messageID)
Return the ActiveMQMessage that matches the Id |
MessageContainerAdmin |
getMessageContainerAdmin()
|
boolean |
isDeadLetterQueue()
returns true if this container is a dead letter queue |
void |
recoverSubscription(Subscription subscription)
A durable subscription has started so recovery any messages that are required. |
void |
registerMessageInterest(MessageIdentity messageIdentity)
Register that a consumer will be interested in this message |
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 |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
void |
storeSubscription(ConsumerInfo info,
Subscription subscription)
Stores the persistence details in the database |
void |
unregisterMessageInterest(MessageIdentity ack)
A message consumer calls this when it's no longer interested in a message so that we know when we can delete (or archive) it |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DurableTopicMessageContainer(DurableTopicMessageContainerManager manager, TopicMessageStore messageStore, String destinationName)
Method Detail |
---|
public String getDestinationName()
getDestinationName
in interface MessageContainer
getDestinationName
in interface MessageContainerAdmin
public void addMessage(ActiveMQMessage message) throws JMSException
MessageContainer
addMessage
in interface MessageContainer
JMSException
public void delete(MessageIdentity messageID, MessageAck ack) throws JMSException
MessageContainer
delete
in interface MessageContainer
JMSException
public boolean containsMessage(MessageIdentity messageIdentity) throws JMSException
MessageContainer
containsMessage
in interface MessageContainer
JMSException
public ActiveMQMessage getMessage(MessageIdentity messageID) throws JMSException
MessageContainer
getMessage
in interface MessageContainer
JMSException
public void registerMessageInterest(MessageIdentity messageIdentity) throws JMSException
MessageContainer
registerMessageInterest
in interface MessageContainer
JMSException
public void unregisterMessageInterest(MessageIdentity ack) throws JMSException
MessageContainer
unregisterMessageInterest
in interface MessageContainer
JMSException
public void setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity) throws JMSException
TopicMessageContainer
setLastAcknowledgedMessageID
in interface TopicMessageContainer
JMSException
public void recoverSubscription(Subscription subscription) throws JMSException
TopicMessageContainer
recoverSubscription
in interface TopicMessageContainer
JMSException
public void storeSubscription(ConsumerInfo info, Subscription subscription) throws JMSException
TopicMessageContainer
storeSubscription
in interface TopicMessageContainer
JMSException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public MessageContainerAdmin getMessageContainerAdmin()
getMessageContainerAdmin
in interface MessageContainer
MessageContainer.getMessageContainerAdmin()
public void empty() throws JMSException
MessageContainerAdmin
empty
in interface MessageContainerAdmin
JMSException
MessageContainerAdmin.empty()
public boolean isDeadLetterQueue()
MessageContainer
isDeadLetterQueue
in interface MessageContainer
MessageContainer.isDeadLetterQueue()
public void deleteSubscription(String sub) throws JMSException
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |