|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.BrokerFilter
org.apache.activemq.broker.view.DotFileInterceptorSupport
org.apache.activemq.broker.view.ConnectionDotFileInterceptor
public class ConnectionDotFileInterceptor
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<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)
|
Methods inherited from class org.apache.activemq.broker.view.DotFileInterceptorSupport |
---|
generateFile |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final java.lang.String ID_SEPARATOR
Constructor Detail |
---|
public ConnectionDotFileInterceptor(Broker next, java.lang.String file, boolean redrawOnRemove) throws java.io.IOException
java.io.IOException
Method Detail |
---|
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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |