org.apache.activemq.broker
Class CompositeDestinationBroker
java.lang.Object
org.apache.activemq.broker.BrokerFilter
org.apache.activemq.broker.CompositeDestinationBroker
- All Implemented Interfaces:
- Broker, Region, Service
public class CompositeDestinationBroker
- extends BrokerFilter
This broker filter handles composite destinations.
If a broker operation is invoked using a composite destination, this filter
repeats the operation using each destination of the composite.
HRC: I think this filter is dangerous to use to with the consumer operations. Multiple
Subscription objects will be associated with a single JMS consumer each having a
different idea of what the current pre-fetch dispatch size is.
If this is used, then the client has to expect many more messages to be dispatched
than the pre-fetch setting allows.
- Version:
- $Revision: 1.8 $
Methods inherited from class org.apache.activemq.broker.BrokerFilter |
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addSession, beginTransaction, commitTransaction, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getPeerBrokerInfos, getPendingDurableSubscriberPolicy, getPreparedTransactions, getTempDataStore, isFaultTolerantConfiguration, isSlaveBroker, isStopped, messagePull, prepareTransaction, processDispatch, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeSession, removeSubscription, rollbackTransaction, setAdminConnectionContext, setPendingDurableSubscriberPolicy, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CompositeDestinationBroker
public CompositeDestinationBroker(Broker next)
addProducer
public void addProducer(ConnectionContext context,
ProducerInfo info)
throws java.lang.Exception
- A producer may register to send to multiple destinations via a composite destination.
- Specified by:
addProducer
in interface Broker
- Overrides:
addProducer
in class BrokerFilter
- Parameters:
context
- the enviorment the operation is being executed under.
- Throws:
java.lang.Exception
- TODO
removeProducer
public void removeProducer(ConnectionContext context,
ProducerInfo info)
throws java.lang.Exception
- A producer may de-register from sending to multiple destinations via a composite destination.
- Specified by:
removeProducer
in interface Broker
- Overrides:
removeProducer
in class BrokerFilter
- Parameters:
context
- the enviorment the operation is being executed under.
- Throws:
java.lang.Exception
- TODO
send
public void send(ConnectionContext context,
Message message)
throws java.lang.Exception
- Description copied from interface:
Region
- Send a message to the broker to using the specified destination. The destination specified
in the message does not need to match the destination the message is sent to. This is
handy in case the message is being sent to a dead letter destination.
- Specified by:
send
in interface Region
- Overrides:
send
in class BrokerFilter
- Parameters:
context
- the environment the operation is being executed under.
- Throws:
java.lang.Exception
- TODO
Copyright © 2009 Apache Software Foundation. All Rights Reserved.