public class DestinationDotFileInterceptor extends DotFileInterceptorSupport
Modifier and Type | Field and Description |
---|---|
protected static String |
ID_SEPARATOR |
next
Constructor and Description |
---|
DestinationDotFileInterceptor(Broker next,
String file) |
Modifier and Type | Method and Description |
---|---|
Destination |
addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
Used to create a destination.
|
protected void |
generateFile(PrintWriter writer) |
protected String |
getPath(DestinationMapNode node) |
protected void |
printNodeLinks(PrintWriter writer,
DestinationMapNode node,
String prefix) |
protected void |
printNodes(PrintWriter writer,
DestinationMapNode node,
String prefix) |
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination.
|
generateFile
acknowledge, addBroker, addConnection, addConsumer, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, 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, removeBroker, removeConnection, removeConsumer, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop
protected static final String ID_SEPARATOR
public Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create) 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
- TODOprotected void generateFile(PrintWriter writer) throws Exception
generateFile
in class DotFileInterceptorSupport
Exception
protected void printNodes(PrintWriter writer, DestinationMapNode node, String prefix)
protected void printNodeLinks(PrintWriter writer, DestinationMapNode node, String prefix)
protected String getPath(DestinationMapNode node)
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.