public class DestinationPathSeparatorBroker extends BrokerPluginSupport
next
Constructor and Description |
---|
DestinationPathSeparatorBroker() |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
Used to acknowledge the receipt of a message by a client.
|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
Destination |
addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
Used to create a destination.
|
void |
addDestinationInfo(ConnectionContext context,
DestinationInfo info)
Add and process a DestinationInfo object
|
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a producer.
|
protected ActiveMQDestination |
convertDestination(ActiveMQDestination destination) |
Response |
messagePull(ConnectionContext context,
MessagePull pull)
Allows a consumer to pull a message from a queue
|
void |
processConsumerControl(ConsumerBrokerExchange consumerExchange,
ConsumerControl control) |
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer.
|
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
void |
removeDestinationInfo(ConnectionContext context,
DestinationInfo info)
Remove and process a DestinationInfo object
|
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
Removes a producer.
|
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Send a message to the broker to using the specified destination.
|
void |
setPathSeparator(String pathSeparator) |
installPlugin, start, stop
getAdaptor, getNext, setNext
addBroker, addConnection, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, 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, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, virtualDestinationAdded, virtualDestinationRemoved
public DestinationPathSeparatorBroker()
protected ActiveMQDestination convertDestination(ActiveMQDestination destination)
public void acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack) throws Exception
Region
acknowledge
in interface Region
acknowledge
in class BrokerFilter
consumerExchange
- the environment the operation is being executed under.Exception
- TODOpublic Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
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 messageSend) throws Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOpublic Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) throws Exception
Region
addDestination
in interface Region
addDestination
in class BrokerFilter
destination
- the destination to create.Exception
- TODOpublic void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws Exception
Region
removeDestination
in interface Region
removeDestination
in class BrokerFilter
context
- the environment the operation is being executed under.destination
- what is being removed from the broker.timeout
- the max amount of time to wait for the destination to quiesceException
- TODOpublic void addDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
Broker
addDestinationInfo
in interface Broker
addDestinationInfo
in class BrokerFilter
Exception
public void removeDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
Broker
removeDestinationInfo
in interface Broker
removeDestinationInfo
in class BrokerFilter
Exception
public void processConsumerControl(ConsumerBrokerExchange consumerExchange, ConsumerControl control)
processConsumerControl
in interface Region
processConsumerControl
in class BrokerFilter
public Response messagePull(ConnectionContext context, MessagePull pull) throws Exception
Region
messagePull
in interface Region
messagePull
in class BrokerFilter
Exception
public void setPathSeparator(String pathSeparator)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.