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

Field Summary

protected static String

ID_SEPARATOR

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

DestinationDotFileInterceptor(Broker next, String file)

Method Summary

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.

Methods inherited from class org.apache.activemq.broker.view.DotFileInterceptorSupport

generateFile

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

Field Detail

ID_SEPARATOR

protected static final String ID_SEPARATOR

See Also:

Constant Field Values

Constructor Detail

DestinationDotFileInterceptor

public DestinationDotFileInterceptor(Broker next,
                                     String file)

Method Detail

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)