org.apache.activemq.broker.view
Class ConnectionDotFileInterceptor

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.ConnectionDotFileInterceptor
All Implemented Interfaces:
Broker, Region, Service

public class ConnectionDotFileInterceptor
extends DotFileInterceptorSupport


Field Summary
protected static String ID_SEPARATOR
           
 
Fields inherited from class org.apache.activemq.broker.BrokerFilter
next
 
Constructor Summary
ConnectionDotFileInterceptor(Broker next, String file, boolean redrawOnRemove)
           
 
Method Summary
 Subscription addConsumer(ConnectionContext context, ConsumerInfo info)
          Adds a consumer.
 void addProducer(ConnectionContext context, ProducerInfo info)
          Adds a producer.
protected  String asID(String name)
          Lets strip out any non supported characters
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)
           
protected  void printProducers(PrintWriter writer, Map<String,String> clients, Map<String,String> queues, Map<String,String> topics)
           
protected  void printProducers(PrintWriter writer, Map<String,String> clients, Map<String,String> queues, Map<String,String> topics, ProducerId producerId, Set destinationSet)
           
protected  void printSubscribers(PrintWriter writer, Map<String,String> clients, Map<String,String> destinations, String type, ObjectName[] subscribers)
           
 void removeConsumer(ConnectionContext context, ConsumerInfo info)
          Removes a consumer.
 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.
protected  void writeLabels(PrintWriter writer, String color, String prefix, Map<String,String> map)
           
 
Methods inherited from class org.apache.activemq.broker.view.DotFileInterceptorSupport
generateFile
 
Methods inherited from class org.apache.activemq.broker.BrokerFilter
acknowledge, addBroker, addConnection, addDestination, addDestinationInfo, 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, removeDestination, removeDestinationInfo, removeSession, removeSubscription, rollbackTransaction, 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

ConnectionDotFileInterceptor

public ConnectionDotFileInterceptor(Broker next,
                                    String file,
                                    boolean redrawOnRemove)
                             throws IOException
Throws:
IOException
Method Detail

addConsumer

public Subscription addConsumer(ConnectionContext context,
                                ConsumerInfo info)
                         throws Exception
Description copied from interface: Region
Adds a consumer.

Specified by:
addConsumer in interface Region
Overrides:
addConsumer in class BrokerFilter
Parameters:
context - the environment the operation is being executed under.
Returns:
TODO
Throws:
Exception - TODO

addProducer

public void addProducer(ConnectionContext context,
                        ProducerInfo info)
                 throws Exception
Description copied from interface: Broker
Adds a producer.

Specified by:
addProducer in interface Broker
Specified by:
addProducer in interface Region
Overrides:
addProducer in class BrokerFilter
Parameters:
context - the enviorment the operation is being executed under.
Throws:
Exception - TODO

removeConsumer

public void removeConsumer(ConnectionContext context,
                           ConsumerInfo info)
                    throws Exception
Description copied from interface: Region
Removes a consumer.

Specified by:
removeConsumer in interface Region
Overrides:
removeConsumer in class BrokerFilter
Parameters:
context - the environment the operation is being executed under.
Throws:
Exception - TODO

removeProducer

public void removeProducer(ConnectionContext context,
                           ProducerInfo info)
                    throws Exception
Description copied from interface: Broker
Removes a producer.

Specified by:
removeProducer in interface Broker
Specified by:
removeProducer in interface Region
Overrides:
removeProducer in class BrokerFilter
Parameters:
context - the enviorment the operation is being executed under.
Throws:
Exception - TODO

send

public void send(ProducerBrokerExchange producerExchange,
                 Message messageSend)
          throws Exception
Description copied from interface: Region
Send a message to the broker to using the specified destination. The destination specified in the message does not need to match the destination the message is sent to. This is handy in case the message is being sent to a dead letter destination.

Specified by:
send in interface Region
Overrides:
send in class BrokerFilter
Parameters:
producerExchange - the environment the operation is being executed under.
Throws:
Exception - TODO

generateFile

protected void generateFile(PrintWriter writer)
                     throws Exception
Specified by:
generateFile in class DotFileInterceptorSupport
Throws:
Exception

printProducers

protected void printProducers(PrintWriter writer,
                              Map<String,String> clients,
                              Map<String,String> queues,
                              Map<String,String> topics)

printProducers

protected void printProducers(PrintWriter writer,
                              Map<String,String> clients,
                              Map<String,String> queues,
                              Map<String,String> topics,
                              ProducerId producerId,
                              Set destinationSet)

printSubscribers

protected void printSubscribers(PrintWriter writer,
                                Map<String,String> clients,
                                Map<String,String> destinations,
                                String type,
                                ObjectName[] subscribers)

writeLabels

protected void writeLabels(PrintWriter writer,
                           String color,
                           String prefix,
                           Map<String,String> map)

asID

protected String asID(String name)
Lets strip out any non supported characters


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.