|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
A Queue based MessageContainer
Method Summary | |
ActiveMQMessage |
peekNext(MessageIdentity messageIdentity)
Used for browsing a MessageContainer this returns the next message in the container after the messageId |
ActiveMQMessage |
poll()
Some implementations may need to poll to fill subscriptions this returns the next message in the container |
void |
recoverMessageToBeDelivered(MessageIdentity messageIdentity)
Invoked during the recovery to add the given message to the end of the messages to be delivered. |
void |
reset()
called to reset dispatch pointers if a new Message Consumer joins |
void |
returnMessage(MessageIdentity messageIdentity)
After a poll() on the Container, if a message can't be dispatched, it is returned |
void |
setDeadLetterQueue(boolean value)
set this MessageContainer to be a dead letter queue |
void |
start()
This container has just been loaded from disk and so it needs to be recovered, that is iterate through all the message IDs in the persistent store and add them to the in memory list of message IDs to be dispatched by consumers |
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 |
stop |
Method Detail |
public ActiveMQMessage poll() throws JMSException
JMSException
public ActiveMQMessage peekNext(MessageIdentity messageIdentity) throws JMSException
messageIdentity
- the id if the message. If this is null, the first message will be retrieved
JMSException
public void returnMessage(MessageIdentity messageIdentity) throws JMSException
messageIdentity
-
JMSException
public void reset() throws JMSException
JMSException
public void start() throws JMSException
start
in interface Service
JMSException
public void recoverMessageToBeDelivered(MessageIdentity messageIdentity) throws JMSException
JMSException
public void setDeadLetterQueue(boolean value)
value
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |