|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.boundedvm.DurableQueueBoundedMessageContainer
public class DurableQueueBoundedMessageContainer
A MessageContainer for Durable queues
Constructor Summary | |
---|---|
DurableQueueBoundedMessageContainer(MessageStore messageStore,
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()
|
String |
getDestinationName()
|
long |
getIdleTimestamp()
|
MessageContainerAdmin |
getMessageContainerAdmin()
|
boolean |
isActive()
|
boolean |
isEmpty()
|
void |
redeliver(DurableMessagePointer message)
|
void |
redeliver(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, 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 JMSException
filter
- info
- client
-
JMSException
public void removeConsumer(ConsumerInfo info) throws JMSException
info
-
JMSException
public void start() throws JMSException
start
in interface Service
JMSException
public void enqueue(ActiveMQMessage message) throws JMSException
message
-
JMSException
public void redeliver(DurableMessagePointer message)
public void redeliver(List messages)
public void stop()
stop
in interface Service
public void close() throws JMSException
JMSException
public void run()
run
in interface Runnable
public ActiveMQDestination getDestination()
public String getDestinationName()
getDestinationName
in interface MessageContainerAdmin
protected void clear()
protected void removeExpiredMessages()
protected void checkRunning()
public MessageContainerAdmin getMessageContainerAdmin()
MessageContainer.getMessageContainerAdmin()
public void empty() throws JMSException
MessageContainerAdmin
empty
in interface MessageContainerAdmin
JMSException
MessageContainerAdmin.empty()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |