|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.impl.MessageContainerManagerSupport
org.activemq.service.impl.DurableQueueMessageContainerManager
A default Broker used for Queue messages
Field Summary | |
protected java.util.Map |
activeSubscriptions
|
protected java.util.Map |
browsers
|
protected DestinationMap |
destinationMap
|
protected FilterFactory |
filterFactory
|
protected java.util.Map |
messagePartSubscribers
|
protected SubscriptionContainer |
subscriptionContainer
|
Fields inherited from class org.activemq.service.impl.MessageContainerManagerSupport |
dispatcher, messageContainers |
Constructor Summary | |
DurableQueueMessageContainerManager(PersistenceAdapter persistenceAdapter,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
|
|
DurableQueueMessageContainerManager(PersistenceAdapter persistenceAdapter,
SubscriptionContainer subscriptionContainer,
FilterFactory filterFactory,
Dispatcher dispatcher)
|
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)
|
protected MessageContainer |
createContainer(java.lang.String destinationName)
Factory method to create a new MessageContainer |
protected javax.jms.Destination |
createDestination(java.lang.String destinationName)
Factory method to create a new Destination |
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 destinationName)
Allows the lookup of a specific named message 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 |
void |
poll()
Poll for messages |
protected void |
processSubscription(Subscription subscription,
QueueMessageContainer container)
|
void |
removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
sendToDeadLetterQueue(java.lang.String deadLetterName,
ActiveMQMessage message)
Add a message to a dead letter queue |
Methods inherited from class org.activemq.service.impl.MessageContainerManagerSupport |
getDeadLetterPolicy, getDestinations, getMessageContainerAdmins, isMaintainDestinationStats, loadContainer, setDeadLetterPolicy, setMaintainDestinationStats, start, stop, updateAcknowledgeStats, updateSendStats |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.activemq.service.MessageContainerManager |
getDeadLetterPolicy, getDestinations, getMessageContainerAdmins, setDeadLetterPolicy |
Methods inherited from interface org.activemq.service.Service |
start, stop |
Field Detail |
protected SubscriptionContainer subscriptionContainer
protected FilterFactory filterFactory
protected java.util.Map activeSubscriptions
protected java.util.Map browsers
protected java.util.Map messagePartSubscribers
protected DestinationMap destinationMap
Constructor Detail |
public DurableQueueMessageContainerManager(PersistenceAdapter persistenceAdapter, RedeliveryPolicy redeliveryPolicy, DeadLetterPolicy deadLetterPolicy)
public DurableQueueMessageContainerManager(PersistenceAdapter persistenceAdapter, SubscriptionContainer subscriptionContainer, FilterFactory filterFactory, Dispatcher dispatcher)
Method Detail |
public java.util.Map getLocalDestinations()
Destination
objects used by non-broker consumers directly connected to this container
getLocalDestinations
in interface MessageContainerManager
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
acknowledgeMessage
in interface MessageContainerManager
client
- ack
-
javax.jms.JMSException
public void poll() throws javax.jms.JMSException
poll
in interface MessageContainerManager
javax.jms.JMSException
public MessageContainer getContainer(java.lang.String destinationName) throws javax.jms.JMSException
MessageContainerManager
getContainer
in interface MessageContainerManager
getContainer
in class MessageContainerManagerSupport
javax.jms.JMSException
protected MessageContainer createContainer(java.lang.String destinationName) throws javax.jms.JMSException
MessageContainerManagerSupport
MessageContainer
createContainer
in class MessageContainerManagerSupport
javax.jms.JMSException
protected javax.jms.Destination createDestination(java.lang.String destinationName)
MessageContainerManagerSupport
Destination
createDestination
in class MessageContainerManagerSupport
protected void processSubscription(Subscription subscription, QueueMessageContainer container) throws javax.jms.JMSException
javax.jms.JMSException
protected Filter createFilter(ConsumerInfo info) throws javax.jms.JMSException
info
-
javax.jms.JMSException
public void createMessageContainer(ActiveMQDestination dest) throws javax.jms.JMSException
MessageContainerManager
createMessageContainer
in interface MessageContainerManager
createMessageContainer
in class MessageContainerManagerSupport
javax.jms.JMSException
public void destroyMessageContainer(ActiveMQDestination dest) throws javax.jms.JMSException
MessageContainerManager
destroyMessageContainer
in interface MessageContainerManager
destroyMessageContainer
in class MessageContainerManagerSupport
javax.jms.JMSException
public void sendToDeadLetterQueue(java.lang.String deadLetterName, ActiveMQMessage message) throws javax.jms.JMSException
sendToDeadLetterQueue
in interface QueueMessageContainerManager
deadLetterName
- message
-
javax.jms.JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |