|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.activemq.service.boundedvm.DurableQueueBoundedMessageContainer
A MessageContainer for Durable queues
| Constructor Summary | |
DurableQueueBoundedMessageContainer(MessageStore messageStore,
EDU.oswego.cs.dl.util.concurrent.Executor threadPool,
MemoryBoundedQueueManager queueManager,
ActiveMQDestination destination,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
Construct this beast |
|
| Method Summary | |
DurableQueueSubscription |
addConsumer(Filter filter,
ConsumerInfo info,
BrokerClient client)
Add a consumer to dispatch messages to |
protected void |
checkRunning()
|
protected void |
clear()
|
void |
close()
close down this container |
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()
|
MessageContainerAdmin |
getMessageContainerAdmin()
|
boolean |
isActive()
|
boolean |
isEmpty()
|
void |
redeliver(DurableMessagePointer message)
|
void |
redeliver(java.util.List messages)
|
void |
removeConsumer(ConsumerInfo info)
Remove a consumer |
protected void |
removeExpiredMessages()
|
void |
run()
do some dispatching |
void |
start()
start working |
void |
stop()
stop working |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
public DurableQueueBoundedMessageContainer(MessageStore messageStore,
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 DurableQueueSubscription 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.JMSException
public void enqueue(ActiveMQMessage message)
throws javax.jms.JMSException
message -
javax.jms.JMSExceptionpublic void redeliver(DurableMessagePointer 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 MessageContainerAdminprotected void clear()
protected void removeExpiredMessages()
protected void checkRunning()
public MessageContainerAdmin getMessageContainerAdmin()
MessageContainer.getMessageContainerAdmin()
public void empty()
throws javax.jms.JMSException
MessageContainerAdmin
empty in interface MessageContainerAdminjavax.jms.JMSExceptionMessageContainerAdmin.empty()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||