|
|||||||||||
| 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 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
acknowledgeMessage in interface MessageContainerManagerclient - ack -
javax.jms.JMSException
public void poll()
throws javax.jms.JMSException
poll in interface MessageContainerManagerjavax.jms.JMSException
public MessageContainer getContainer(java.lang.String destinationName)
throws javax.jms.JMSException
MessageContainerManager
getContainer in interface MessageContainerManagergetContainer in class MessageContainerManagerSupportjavax.jms.JMSException
protected MessageContainer createContainer(java.lang.String destinationName)
throws javax.jms.JMSException
MessageContainerManagerSupportMessageContainer
createContainer in class MessageContainerManagerSupportjavax.jms.JMSExceptionprotected javax.jms.Destination createDestination(java.lang.String destinationName)
MessageContainerManagerSupportDestination
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 MessageContainerManagercreateMessageContainer in class MessageContainerManagerSupportjavax.jms.JMSException
public void destroyMessageContainer(ActiveMQDestination dest)
throws javax.jms.JMSException
MessageContainerManager
destroyMessageContainer in interface MessageContainerManagerdestroyMessageContainer in class MessageContainerManagerSupportjavax.jms.JMSException
public void sendToDeadLetterQueue(java.lang.String deadLetterName,
ActiveMQMessage message)
throws javax.jms.JMSException
sendToDeadLetterQueue in interface QueueMessageContainerManagerdeadLetterName - message -
javax.jms.JMSException
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||