org.apache.activemq.broker.view
Class DestinationDotFileInterceptor
java.lang.Object
org.apache.activemq.broker.BrokerFilter
org.apache.activemq.broker.view.DotFileInterceptorSupport
org.apache.activemq.broker.view.DestinationDotFileInterceptor
- All Implemented Interfaces:
- Broker, Region, Service
public class DestinationDotFileInterceptor
- extends DotFileInterceptorSupport
Methods inherited from class org.apache.activemq.broker.BrokerFilter |
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ID_SEPARATOR
protected static final String ID_SEPARATOR
- See Also:
- Constant Field Values
DestinationDotFileInterceptor
public DestinationDotFileInterceptor(Broker next,
String file)
addDestination
public Destination addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create)
throws Exception
- Description copied from interface:
Region
- Used to create a destination. Usually, this method is invoked as a side-effect of sending
a message to a destination that does not exist yet.
- Specified by:
addDestination
in interface Region
- Overrides:
addDestination
in class BrokerFilter
destination
- the destination to create.
- Returns:
- TODO
- Throws:
Exception
- TODO
removeDestination
public void removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
throws Exception
- Description copied from interface:
Region
- Used to destroy a destination.
This should try to quiesce use of the destination up to the timeout allotted time before removing the destination.
This will remove all persistent messages associated with the destination.
- Specified by:
removeDestination
in interface Region
- Overrides:
removeDestination
in class BrokerFilter
- Parameters:
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 quiesce
- Throws:
Exception
- TODO
generateFile
protected void generateFile(PrintWriter writer)
throws Exception
- Specified by:
generateFile
in class DotFileInterceptorSupport
- Throws:
Exception
printNodes
protected void printNodes(PrintWriter writer,
DestinationMapNode node,
String prefix)
printNodeLinks
protected void printNodeLinks(PrintWriter writer,
DestinationMapNode node,
String prefix)
getPath
protected String getPath(DestinationMapNode node)
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.