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

Version:

$Revision: $

Field Summary

protected static java.lang.String

ID_SEPARATOR

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

next

Constructor Summary

ConnectionDotFileInterceptor(Broker next, java.lang.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 java.lang.String	asID(java.lang.String name) Lets strip out any non supported characters
protected void	generateFile(java.io.PrintWriter writer)
protected java.lang.String	getPath(DestinationMapNode node)
protected void	printNodeLinks(java.io.PrintWriter writer, DestinationMapNode node, java.lang.String prefix)
protected void	printNodes(java.io.PrintWriter writer, DestinationMapNode node, java.lang.String prefix)
protected void	printProducers(java.io.PrintWriter writer, java.util.Map clients, java.util.Map queues, java.util.Map topics)
protected void	printProducers(java.io.PrintWriter writer, java.util.Map clients, java.util.Map queues, java.util.Map topics, ProducerId producerId, java.util.Set destinationSet)
protected void	printSubscribers(java.io.PrintWriter writer, java.util.Map clients, java.util.Map destinations, java.lang.String type, javax.management.ObjectName[] subscribers)
void	removeConsumer(ConnectionContext context, ConsumerInfo info) Removes a consumer.
void	removeProducer(ConnectionContext context, ProducerInfo info) Removes a producer.
void	send(ConnectionContext context, Message messageSend) Send a message to the broker to using the specified destination.
protected void	writeLabels(java.io.PrintWriter writer, java.lang.String color, java.lang.String prefix, java.util.Map 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, commitTransaction, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getPeerBrokerInfos, getPendingDurableSubscriberPolicy, getPreparedTransactions, getTempDataStore, isFaultTolerantConfiguration, isSlaveBroker, isStopped, messagePull, prepareTransaction, processDispatch, processDispatchNotification, removeBroker, removeConnection, removeDestination, removeDestinationInfo, removeSession, removeSubscription, rollbackTransaction, setAdminConnectionContext, setPendingDurableSubscriberPolicy, 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 java.lang.String ID_SEPARATOR

See Also:

Constant Field Values

Constructor Detail

ConnectionDotFileInterceptor

public ConnectionDotFileInterceptor(Broker next,
                                    java.lang.String file,
                                    boolean redrawOnRemove)
                             throws javax.management.MalformedObjectNameException

Throws:

javax.management.MalformedObjectNameException

Method Detail

addConsumer

public Subscription addConsumer(ConnectionContext context,
                                ConsumerInfo info)
                         throws java.lang.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:

java.lang.Exception - TODO

addProducer

public void addProducer(ConnectionContext context,
                        ProducerInfo info)
                 throws java.lang.Exception

Description copied from interface: Broker

Adds a producer.

Specified by:

addProducer in interface Broker

Overrides:

addProducer in class BrokerFilter

Parameters:

context - the enviorment the operation is being executed under.

Throws:

java.lang.Exception - TODO

removeConsumer

public void removeConsumer(ConnectionContext context,
                           ConsumerInfo info)
                    throws java.lang.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:

java.lang.Exception - TODO

removeProducer

public void removeProducer(ConnectionContext context,
                           ProducerInfo info)
                    throws java.lang.Exception

Description copied from interface: Broker

Removes a producer.

Specified by:

removeProducer in interface Broker

Overrides:

removeProducer in class BrokerFilter

Parameters:

context - the enviorment the operation is being executed under.

Throws:

java.lang.Exception - TODO

send

public void send(ConnectionContext context,
                 Message messageSend)
          throws java.lang.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:

context - the environment the operation is being executed under.

Throws:

java.lang.Exception - TODO

generateFile

protected void generateFile(java.io.PrintWriter writer)
                     throws java.lang.Exception

Specified by:

generateFile in class DotFileInterceptorSupport

Throws:

java.lang.Exception

printProducers

protected void printProducers(java.io.PrintWriter writer,
                              java.util.Map clients,
                              java.util.Map queues,
                              java.util.Map topics)

printProducers

protected void printProducers(java.io.PrintWriter writer,
                              java.util.Map clients,
                              java.util.Map queues,
                              java.util.Map topics,
                              ProducerId producerId,
                              java.util.Set destinationSet)

printSubscribers

protected void printSubscribers(java.io.PrintWriter writer,
                                java.util.Map clients,
                                java.util.Map destinations,
                                java.lang.String type,
                                javax.management.ObjectName[] subscribers)

writeLabels

protected void writeLabels(java.io.PrintWriter writer,
                           java.lang.String color,
                           java.lang.String prefix,
                           java.util.Map map)

asID

protected java.lang.String asID(java.lang.String name)

Lets strip out any non supported characters

printNodes

protected void printNodes(java.io.PrintWriter writer,
                          DestinationMapNode node,
                          java.lang.String prefix)

printNodeLinks

protected void printNodeLinks(java.io.PrintWriter writer,
                              DestinationMapNode node,
                              java.lang.String prefix)

getPath

protected java.lang.String getPath(DestinationMapNode node)