org.apache.activemq.broker.view

Class ConnectionDotFileInterceptor

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.broker.view.DotFileInterceptorSupport

org.apache.activemq.broker.view.ConnectionDotFileInterceptor

All Implemented Interfaces:

Broker, Region, Service

public class ConnectionDotFileInterceptor
extends DotFileInterceptorSupport

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	ID_SEPARATOR

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

next

Constructor Summary

Constructors

Constructor and Description
ConnectionDotFileInterceptor(Broker next, String file, boolean redrawOnRemove)

Method Summary

Modifier and Type	Method and Description
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, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getNext, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeDestination, removeDestinationInfo, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop, virtualDestinationAdded, virtualDestinationRemoved

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 environment 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 environment 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)