Package 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
-
public class ConnectionDotFileInterceptor extends DotFileInterceptorSupport
-
-
Field Summary
Fields Modifier and Type Field Description protected static String
ID_SEPARATOR
-
Fields inherited from class org.apache.activemq.broker.BrokerFilter
next
-
-
Constructor Summary
Constructors Constructor Description ConnectionDotFileInterceptor(Broker next, String file, boolean redrawOnRemove)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 charactersprotected 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
-
-
-
-
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 interfaceRegion
- Overrides:
addConsumer
in classBrokerFilter
- 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 interfaceBroker
- Specified by:
addProducer
in interfaceRegion
- Overrides:
addProducer
in classBrokerFilter
- 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 interfaceRegion
- Overrides:
removeConsumer
in classBrokerFilter
- 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 interfaceBroker
- Specified by:
removeProducer
in interfaceRegion
- Overrides:
removeProducer
in classBrokerFilter
- 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 interfaceRegion
- Overrides:
send
in classBrokerFilter
- 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 classDotFileInterceptorSupport
- 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)
-
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)
-
-