org.apache.activemq.broker.view
public class ConnectionDotFileInterceptor extends DotFileInterceptorSupport
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
ID_SEPARATOR |
next
Constructor and Description |
---|
ConnectionDotFileInterceptor(Broker next,
java.lang.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 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<java.lang.String,java.lang.String> clients,
java.util.Map<java.lang.String,java.lang.String> queues,
java.util.Map<java.lang.String,java.lang.String> topics) |
protected void |
printProducers(java.io.PrintWriter writer,
java.util.Map<java.lang.String,java.lang.String> clients,
java.util.Map<java.lang.String,java.lang.String> queues,
java.util.Map<java.lang.String,java.lang.String> topics,
ProducerId producerId,
java.util.Set destinationSet) |
protected void |
printSubscribers(java.io.PrintWriter writer,
java.util.Map<java.lang.String,java.lang.String> clients,
java.util.Map<java.lang.String,java.lang.String> 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(ProducerBrokerExchange producerExchange,
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<java.lang.String,java.lang.String> map) |
generateFile
acknowledge, addBroker, addConnection, addDestination, addDestinationInfo, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeConnection, removeDestination, removeDestinationInfo, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop
protected static final java.lang.String ID_SEPARATOR
public ConnectionDotFileInterceptor(Broker next, java.lang.String file, boolean redrawOnRemove) throws java.io.IOException
java.io.IOException
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.java.lang.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.java.lang.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.java.lang.Exception
- TODOpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws java.lang.Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.java.lang.Exception
- TODOprotected void generateFile(java.io.PrintWriter writer) throws java.lang.Exception
generateFile
in class DotFileInterceptorSupport
java.lang.Exception
protected void printProducers(java.io.PrintWriter writer, java.util.Map<java.lang.String,java.lang.String> clients, java.util.Map<java.lang.String,java.lang.String> queues, java.util.Map<java.lang.String,java.lang.String> topics)
protected void printProducers(java.io.PrintWriter writer, java.util.Map<java.lang.String,java.lang.String> clients, java.util.Map<java.lang.String,java.lang.String> queues, java.util.Map<java.lang.String,java.lang.String> topics, ProducerId producerId, java.util.Set destinationSet)
protected void printSubscribers(java.io.PrintWriter writer, java.util.Map<java.lang.String,java.lang.String> clients, java.util.Map<java.lang.String,java.lang.String> destinations, java.lang.String type, javax.management.ObjectName[] subscribers)
protected void writeLabels(java.io.PrintWriter writer, java.lang.String color, java.lang.String prefix, java.util.Map<java.lang.String,java.lang.String> map)
protected java.lang.String asID(java.lang.String name)
protected void printNodes(java.io.PrintWriter writer, DestinationMapNode node, java.lang.String prefix)
protected void printNodeLinks(java.io.PrintWriter writer, DestinationMapNode node, java.lang.String prefix)
protected java.lang.String getPath(DestinationMapNode node)
Copyright © 2005-2014. All Rights Reserved.