|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.activemq.service.boundedvm.TransientTopicBoundedMessageManager
A manager of MessageContainer instances
| Constructor Summary | |
TransientTopicBoundedMessageManager(MemoryBoundedQueueManager mgr)
Constructor for TransientTopicBoundedMessageManager |
|
| 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)
For Transient topics - a MessageContainer maps on to the messages to be dispatched through a BrokerClient, not a destination |
DeadLetterPolicy |
getDeadLetterPolicy()
|
java.util.Map |
getDestinations()
Returns an unmodifiable map, indexed by String name, of all the Destination
objects available in this container |
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 boolean |
hasConsumerFor(ActiveMQDestination destination)
|
boolean |
isDecoupledDispatch()
|
void |
poll()
Poll for messages |
void |
removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
setDeadLetterPolicy(DeadLetterPolicy policy)
Set the DeadLetterPolicy for this Container Manager |
void |
setDecoupledDispatch(boolean decoupledDispatch)
|
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 TransientTopicBoundedMessageManager(MemoryBoundedQueueManager mgr)
mgr - | Method Detail |
public void start()
throws javax.jms.JMSException
start in interface Servicejavax.jms.JMSException
public void stop()
throws javax.jms.JMSException
stop in interface Servicejavax.jms.JMSException
public void addMessageConsumer(BrokerClient client,
ConsumerInfo info)
throws javax.jms.JMSException
addMessageConsumer in interface MessageContainerManagerclient - info -
javax.jms.JMSException
public void removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
throws javax.jms.JMSException
removeMessageConsumer in interface MessageContainerManagerclient - info -
javax.jms.JMSException
public void deleteSubscription(java.lang.String clientId,
java.lang.String subscriberName)
throws javax.jms.JMSException
deleteSubscription in interface MessageContainerManagerclientId - subscriberName -
javax.jms.JMSException - if the subscriber doesn't exist or is still active
public void sendMessage(BrokerClient client,
ActiveMQMessage message)
throws javax.jms.JMSException
sendMessage in interface MessageContainerManagerclient - message -
javax.jms.JMSException
public void acknowledgeMessage(BrokerClient client,
MessageAck ack)
throws javax.jms.JMSException
MessageContainerManager
acknowledgeMessage in interface MessageContainerManagerclient - ack -
javax.jms.JMSException
public void poll()
throws javax.jms.JMSException
MessageContainerManager
poll in interface MessageContainerManagerjavax.jms.JMSException
public MessageContainer getContainer(java.lang.String physicalName)
throws javax.jms.JMSException
getContainer in interface MessageContainerManagerphysicalName -
javax.jms.JMSExceptionpublic java.util.Map getDestinations()
MessageContainerManagerDestination
objects available in this container
getDestinations in interface MessageContainerManagerpublic java.util.Map getLocalDestinations()
Destination
objects used by non-broker consumers directly connected to this container
getLocalDestinations in interface MessageContainerManagerpublic DeadLetterPolicy getDeadLetterPolicy()
getDeadLetterPolicy in interface MessageContainerManagerpublic void setDeadLetterPolicy(DeadLetterPolicy policy)
setDeadLetterPolicy in interface MessageContainerManagerpolicy - public boolean isDecoupledDispatch()
public void setDecoupledDispatch(boolean decoupledDispatch)
decoupledDispatch - The decoupledDispatch to set.
protected Filter createFilter(ConsumerInfo info)
throws javax.jms.JMSException
info -
javax.jms.JMSExceptionprotected boolean hasConsumerFor(ActiveMQDestination destination)
public void createMessageContainer(ActiveMQDestination dest)
throws javax.jms.JMSException
MessageContainerManager
createMessageContainer in interface MessageContainerManagerdest -
javax.jms.JMSExceptionMessageContainerManager.createMessageContainer(org.activemq.message.ActiveMQDestination)
public void destroyMessageContainer(ActiveMQDestination dest)
throws javax.jms.JMSException
MessageContainerManager
destroyMessageContainer in interface MessageContainerManagerdest -
javax.jms.JMSExceptionMessageContainerManager.destroyMessageContainer(org.activemq.message.ActiveMQDestination)
public java.util.Map getMessageContainerAdmins()
throws javax.jms.JMSException
MessageContainerManagerMessageContainerAdmin
objects available in this container
getMessageContainerAdmins in interface MessageContainerManagerjavax.jms.JMSExceptionMessageContainerManager.getMessageContainerAdmins()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||