|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.boundedvm.TransientQueueBoundedMessageManager
A manager of MessageContainer instances
Nested Class Summary | |
protected static class |
TransientQueueBoundedMessageManager.TransientQueueThreadFactory
|
Constructor Summary | |
TransientQueueBoundedMessageManager(MemoryBoundedQueueManager mgr,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
Constructor for TransientQueueBoundedMessageManager |
Method Summary | |
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge a message as being read and consumed by the Consumer |
void |
addMessageConsumer(BrokerClient client,
ConsumerInfo info)
Add a consumer if appropiate |
protected Filter |
createFilter(ConsumerInfo info)
Create filter for a Consumer |
void |
createMessageContainer(ActiveMQDestination dest)
Creates a destination. |
void |
deleteSubscription(java.lang.String clientId,
java.lang.String subscriberName)
Delete a durable subscriber |
void |
destroyMessageContainer(ActiveMQDestination dest)
Destroys a destination. |
MessageContainer |
getContainer(java.lang.String physicalName)
Allows the lookup of a specific named message container |
DeadLetterPolicy |
getDeadLetterPolicy()
|
java.util.Map |
getDestinations()
Returns an unmodifiable map, indexed by String name, of all the Destination
objects available in this container |
int |
getGarbageCoolectionCapacityLimit()
|
long |
getInactiveTimeout()
|
java.util.Map |
getLocalDestinations()
Returns an unmodifiable map, indexed by String name, of all the Destination
objects used by non-broker consumers directly connected to this container |
java.util.Map |
getMessageContainerAdmins()
Returns an unmodifiable map, indexed by ActiveMQDestination, of all the MessageContainerAdmin
objects available in this container |
protected EDU.oswego.cs.dl.util.concurrent.Executor |
getThreadPool()
|
void |
poll()
Poll for messages |
void |
removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
void |
run()
collect expired messages |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
setDeadLetterPolicy(DeadLetterPolicy policy)
Set the DeadLetterPolicy for this Container Manager |
void |
setGarbageCoolectionCapacityLimit(int garbageCoolectionCapacityLimit)
|
void |
setInactiveTimeout(long inactiveTimeout)
|
void |
start()
start the manager |
void |
stop()
stop the manager |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TransientQueueBoundedMessageManager(MemoryBoundedQueueManager mgr, RedeliveryPolicy redeliveryPolicy, DeadLetterPolicy deadLetterPolicy)
mgr
- redeliveryPolicy
- deadLetterPolicy
- Method Detail |
public int getGarbageCoolectionCapacityLimit()
public void setGarbageCoolectionCapacityLimit(int garbageCoolectionCapacityLimit)
garbageCoolectionCapacityLimit
- The garbageCoolectionCapacityLimit to set.public long getInactiveTimeout()
public void setInactiveTimeout(long inactiveTimeout)
inactiveTimeout
- The inactiveTimeout to set.public void start() throws javax.jms.JMSException
start
in interface Service
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface Service
javax.jms.JMSException
public void run()
run
in interface java.lang.Runnable
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws javax.jms.JMSException
addMessageConsumer
in interface MessageContainerManager
client
- info
-
javax.jms.JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws javax.jms.JMSException
removeMessageConsumer
in interface MessageContainerManager
client
- info
-
javax.jms.JMSException
public void deleteSubscription(java.lang.String clientId, java.lang.String subscriberName) throws javax.jms.JMSException
deleteSubscription
in interface MessageContainerManager
clientId
- subscriberName
-
javax.jms.JMSException
- if the subscriber doesn't exist or is still activepublic void sendMessage(BrokerClient client, ActiveMQMessage message) throws javax.jms.JMSException
sendMessage
in interface MessageContainerManager
client
- message
-
javax.jms.JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws javax.jms.JMSException
MessageContainerManager
acknowledgeMessage
in interface MessageContainerManager
client
- ack
-
javax.jms.JMSException
public void poll() throws javax.jms.JMSException
MessageContainerManager
poll
in interface MessageContainerManager
javax.jms.JMSException
public MessageContainer getContainer(java.lang.String physicalName) throws javax.jms.JMSException
MessageContainerManager
getContainer
in interface MessageContainerManager
physicalName
-
javax.jms.JMSException
public java.util.Map getDestinations()
MessageContainerManager
Destination
objects available in this container
getDestinations
in interface MessageContainerManager
public java.util.Map getLocalDestinations()
Destination
objects used by non-broker consumers directly connected to this container
getLocalDestinations
in interface MessageContainerManager
public DeadLetterPolicy getDeadLetterPolicy()
getDeadLetterPolicy
in interface MessageContainerManager
public void setDeadLetterPolicy(DeadLetterPolicy policy)
setDeadLetterPolicy
in interface MessageContainerManager
policy
- protected Filter createFilter(ConsumerInfo info) throws javax.jms.JMSException
info
-
javax.jms.JMSException
protected EDU.oswego.cs.dl.util.concurrent.Executor getThreadPool()
public void createMessageContainer(ActiveMQDestination dest) throws javax.jms.JMSException
MessageContainerManager
createMessageContainer
in interface MessageContainerManager
dest
-
javax.jms.JMSException
public void destroyMessageContainer(ActiveMQDestination dest) throws javax.jms.JMSException
MessageContainerManager
destroyMessageContainer
in interface MessageContainerManager
dest
-
javax.jms.JMSException
public java.util.Map getMessageContainerAdmins() throws javax.jms.JMSException
MessageContainerManager
MessageContainerAdmin
objects available in this container
getMessageContainerAdmins
in interface MessageContainerManager
javax.jms.JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |