public class ConnectionDotFileInterceptor extends DotFileInterceptorSupport
Modifier and Type | Field and Description |
---|---|
protected static String |
ID_SEPARATOR |
next
Constructor and Description |
---|
ConnectionDotFileInterceptor(Broker next,
String file,
boolean redrawOnRemove) |
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) |
generateFile
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
protected static final String ID_SEPARATOR
public ConnectionDotFileInterceptor(Broker next, String file, boolean redrawOnRemove) throws IOException
IOException
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOprotected void generateFile(PrintWriter writer) throws Exception
generateFile
in class DotFileInterceptorSupport
Exception
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)
protected void writeLabels(PrintWriter writer, String color, String prefix, Map<String,String> map)
protected void printNodes(PrintWriter writer, DestinationMapNode node, String prefix)
protected void printNodeLinks(PrintWriter writer, DestinationMapNode node, String prefix)
protected String getPath(DestinationMapNode node)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.