|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.activemq.service.boundedvm.TransientQueueBoundedMessageContainer
A MessageContainer for transient queues
| Constructor Summary | |
TransientQueueBoundedMessageContainer(EDU.oswego.cs.dl.util.concurrent.Executor threadPool,
MemoryBoundedQueueManager queueManager,
ActiveMQDestination destination,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
Construct this beast |
|
| Method Summary | |
TransientQueueSubscription |
addConsumer(Filter filter,
ConsumerInfo info,
BrokerClient client)
Add a consumer to dispatch messages to |
void |
addMessage(ActiveMQMessage msg)
Add an ActiveMQMessage to the message container |
protected void |
clear()
|
void |
close()
close down this 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 messageIdentity,
MessageAck ack)
Delete a message - if no |
void |
empty()
Deletes all the messages that a container holds. |
void |
enqueue(ActiveMQMessage message)
enqueue a message for dispatching |
ActiveMQDestination |
getDestination()
|
java.lang.String |
getDestinationName()
|
long |
getIdleTimestamp()
|
ActiveMQMessage |
getMessage(MessageIdentity messageIdentity)
Return the ActiveMQMessage that matches the Id |
MessageContainerAdmin |
getMessageContainerAdmin()
|
boolean |
isActive()
|
boolean |
isDeadLetterQueue()
returns true if this container is a dead letter queue |
boolean |
isEmpty()
|
void |
redeliver(ActiveMQMessage message)
re-enqueue a message for dispatching |
void |
redeliver(java.util.List messages)
|
void |
registerMessageInterest(MessageIdentity messageIdentity)
Register that a consumer will be interested in this message |
void |
removeConsumer(ConsumerInfo info)
Remove a consumer |
protected void |
removeExpiredMessages()
|
void |
run()
do some dispatching |
void |
start()
start working |
protected void |
startRunning()
|
void |
stop()
stop working |
void |
unregisterMessageInterest(MessageIdentity messageIdentity)
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 TransientQueueBoundedMessageContainer(EDU.oswego.cs.dl.util.concurrent.Executor threadPool,
MemoryBoundedQueueManager queueManager,
ActiveMQDestination destination,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
threadPool - queueManager - destination - redeliveryPolicy - deadLetterPolicy - | Method Detail |
public boolean isActive()
public boolean isEmpty()
public long getIdleTimestamp()
public TransientQueueSubscription addConsumer(Filter filter,
ConsumerInfo info,
BrokerClient client)
throws javax.jms.JMSException
filter - info - client -
javax.jms.JMSException
public void removeConsumer(ConsumerInfo info)
throws javax.jms.JMSException
info -
javax.jms.JMSException
public void start()
throws javax.jms.JMSException
start in interface Servicejavax.jms.JMSExceptionpublic void enqueue(ActiveMQMessage message)
message - public void redeliver(ActiveMQMessage message)
message - public void redeliver(java.util.List messages)
public void stop()
stop in interface Service
public void close()
throws javax.jms.JMSException
javax.jms.JMSExceptionpublic void run()
run in interface java.lang.Runnablepublic ActiveMQDestination getDestination()
public java.lang.String getDestinationName()
getDestinationName in interface MessageContainer
public void addMessage(ActiveMQMessage msg)
throws javax.jms.JMSException
MessageContainer
addMessage in interface MessageContainermsg -
javax.jms.JMSException
public void delete(MessageIdentity messageIdentity,
MessageAck ack)
throws javax.jms.JMSException
MessageContainer
delete in interface MessageContainermessageIdentity - ack -
javax.jms.JMSException
public ActiveMQMessage getMessage(MessageIdentity messageIdentity)
throws javax.jms.JMSException
MessageContainer
getMessage in interface MessageContainermessageIdentity -
javax.jms.JMSException
public void registerMessageInterest(MessageIdentity messageIdentity)
throws javax.jms.JMSException
MessageContainer
registerMessageInterest in interface MessageContainermessageIdentity -
javax.jms.JMSException
public void unregisterMessageInterest(MessageIdentity messageIdentity)
throws javax.jms.JMSException
MessageContainer
unregisterMessageInterest in interface MessageContainermessageIdentity -
javax.jms.JMSException
public boolean containsMessage(MessageIdentity messageIdentity)
throws javax.jms.JMSException
MessageContainer
containsMessage in interface MessageContainermessageIdentity -
javax.jms.JMSExceptionprotected void clear()
protected void removeExpiredMessages()
protected void startRunning()
public MessageContainerAdmin getMessageContainerAdmin()
getMessageContainerAdmin in interface MessageContainerMessageContainer.getMessageContainerAdmin()
public void empty()
throws javax.jms.JMSException
MessageContainerAdmin
empty in interface MessageContainerAdminjavax.jms.JMSExceptionMessageContainerAdmin.empty()public boolean isDeadLetterQueue()
MessageContainer
isDeadLetterQueue in interface MessageContainerMessageContainer.isDeadLetterQueue()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||