public class CompositeDestinationBroker extends BrokerFilter
next
Constructor and Description |
---|
CompositeDestinationBroker(Broker next) |
Modifier and Type | Method and Description |
---|---|
void |
addProducer(ConnectionContext context,
ProducerInfo info)
A producer may register to send to multiple destinations via a composite
destination.
|
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
A producer may de-register from sending to multiple destinations via a
composite destination.
|
void |
send(ProducerBrokerExchange producerExchange,
Message message)
Send a message to the broker to using the specified destination.
|
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop, virtualDestinationAdded, virtualDestinationRemoved
public CompositeDestinationBroker(Broker next)
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void send(ProducerBrokerExchange producerExchange, Message message) throws Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOCopyright © 2005–2017 The Apache Software Foundation. All rights reserved.