org.apache.activemq.broker.view
Class DestinationDotFileInterceptor

java.lang.Object
  extended by org.apache.activemq.broker.BrokerFilter
      extended by org.apache.activemq.broker.view.DotFileInterceptorSupport
          extended by 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)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.