|
||||||||||
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.DurableTopicMessageContainerManager
public class DurableTopicMessageContainerManager
A default Broker used for Topic messages for durable consumers
Field Summary | |
---|---|
protected Map |
activeSubscriptions
|
protected FilterFactory |
filterFactory
|
protected SubscriptionContainer |
subscriptionContainer
|
Fields inherited from class org.activemq.service.impl.MessageContainerManagerSupport |
---|
dispatcher, messageContainers |
Constructor Summary | |
---|---|
DurableTopicMessageContainerManager(PersistenceAdapter persistenceAdapter,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
|
|
DurableTopicMessageContainerManager(PersistenceAdapter persistenceAdapter,
SubscriptionContainer subscriptionContainer,
FilterFactory filterFactory,
Dispatcher dispatcher)
|
Method Summary | |
---|---|
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge a message as being read and consumed byh the Consumer |
void |
addMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
protected MessageContainer |
createContainer(String destinationName)
Factory method to create a new MessageContainer |
protected Destination |
createDestination(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(String clientId,
String subscriberName)
Delete a durable subscriber |
void |
destroyMessageContainer(ActiveMQDestination dest)
Destroys a destination. |
protected void |
doAddMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
protected boolean |
equal(Object o1,
Object o2)
Returns true if the two objects are null or are equal |
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 |
boolean |
isConsumerActiveOnDestination(ActiveMQDestination dest)
|
protected void |
loadAllMessageContainers()
Called when recovering a wildcard subscription where we need to load all the durable message containers (for which we have any outstanding messages to deliver) into RAM |
void |
poll()
poll or messages |
protected void |
recoverSubscriptions(Subscription subscription)
This method is called when a new durable subscription is started and so we need to go through each matching message container and dispatch any matching messages that may be outstanding |
void |
removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
|
Methods inherited from class org.activemq.service.impl.MessageContainerManagerSupport |
---|
getContainer, 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 |
Field Detail |
---|
protected SubscriptionContainer subscriptionContainer
protected FilterFactory filterFactory
protected Map activeSubscriptions
Constructor Detail |
---|
public DurableTopicMessageContainerManager(PersistenceAdapter persistenceAdapter, RedeliveryPolicy redeliveryPolicy, DeadLetterPolicy deadLetterPolicy)
public DurableTopicMessageContainerManager(PersistenceAdapter persistenceAdapter, SubscriptionContainer subscriptionContainer, FilterFactory filterFactory, Dispatcher dispatcher)
Method Detail |
---|
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
public void deleteSubscription(String clientId, String subscriberName) throws JMSException
clientId
- subscriberName
-
JMSException
- if the subscriber doesn't exist or is still activepublic void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
client
- message
-
JMSException
public Map getLocalDestinations()
Destination
objects used by non-broker consumers directly connected to this container
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
client
- ack
-
JMSException
public void poll() throws JMSException
JMSException
protected MessageContainer createContainer(String destinationName) throws JMSException
MessageContainerManagerSupport
MessageContainer
createContainer
in class MessageContainerManagerSupport
JMSException
protected Destination createDestination(String destinationName)
MessageContainerManagerSupport
Destination
createDestination
in class MessageContainerManagerSupport
public boolean isConsumerActiveOnDestination(ActiveMQDestination dest)
protected void doAddMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
JMSException
protected final boolean equal(Object o1, Object o2)
protected void recoverSubscriptions(Subscription subscription) throws JMSException
subscription
-
JMSException
protected void loadAllMessageContainers() throws JMSException
JMSException
protected Filter createFilter(ConsumerInfo info) throws JMSException
info
-
JMSException
public void createMessageContainer(ActiveMQDestination dest) throws JMSException
MessageContainerManager
createMessageContainer
in interface MessageContainerManager
createMessageContainer
in class MessageContainerManagerSupport
JMSException
public void destroyMessageContainer(ActiveMQDestination dest) throws JMSException
MessageContainerManager
destroyMessageContainer
in interface MessageContainerManager
destroyMessageContainer
in class MessageContainerManagerSupport
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |