Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » view » [javadoc | source]
org.apache.activemq.broker.view
public class: ConnectionDotFileInterceptor [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.BrokerFilter
      org.apache.activemq.broker.view.DotFileInterceptorSupport
         org.apache.activemq.broker.view.ConnectionDotFileInterceptor

All Implemented Interfaces:
    Broker

Field Summary
protected static final  String ID_SEPARATOR     
Fields inherited from org.apache.activemq.broker.BrokerFilter:
next
Constructor:
 public ConnectionDotFileInterceptor(Broker next,
    String file,
    boolean redrawOnRemove) throws IOException 
Method from org.apache.activemq.broker.view.ConnectionDotFileInterceptor Summary:
addConsumer,   addProducer,   asID,   generateFile,   getBrokerView,   getPath,   printNodeLinks,   printNodes,   printProducers,   printProducers,   printSubscribers,   removeConsumer,   removeProducer,   send,   writeLabels
Methods from org.apache.activemq.broker.view.DotFileInterceptorSupport:
generateFile,   generateFile
Methods from org.apache.activemq.broker.BrokerFilter:
acknowledge,   addBroker,   addConnection,   addConsumer,   addDestination,   addDestinationInfo,   addProducer,   addSession,   beginTransaction,   brokerServiceStarted,   commitTransaction,   fastProducer,   forgetTransaction,   gc,   getAdaptor,   getAdminConnectionContext,   getBrokerId,   getBrokerName,   getBrokerSequenceId,   getBrokerService,   getClients,   getDestinationMap,   getDestinations,   getDestinations,   getDurableDestinations,   getPeerBrokerInfos,   getPreparedTransactions,   getRoot,   getTempDataStore,   getVmConnectorURI,   isExpired,   isFaultTolerantConfiguration,   isFull,   isStopped,   messageConsumed,   messageDelivered,   messageDiscarded,   messageExpired,   messagePull,   nowMasterBroker,   postProcessDispatch,   preProcessDispatch,   prepareTransaction,   processDispatchNotification,   removeBroker,   removeConnection,   removeConsumer,   removeDestination,   removeDestinationInfo,   removeProducer,   removeSession,   removeSubscription,   rollbackTransaction,   send,   sendToDeadLetterQueue,   setAdminConnectionContext,   slowConsumer,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.view.ConnectionDotFileInterceptor Detail:
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void addProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 protected String asID(String name) 
    Lets strip out any non supported characters
 protected  void generateFile(PrintWriter writer) throws Exception 
 BrokerViewMBean getBrokerView() throws Exception 
 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) 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message messageSend) throws Exception 
 protected  void writeLabels(PrintWriter writer,
    String color,
    String prefix,
    Map<String, String> map)