Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » util » [javadoc | source]
org.apache.activemq.broker.util
public class: UDPTraceBrokerPlugin [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.MutableBrokerFilter
      org.apache.activemq.broker.BrokerPluginSupport
         org.apache.activemq.broker.util.UDPTraceBrokerPlugin

All Implemented Interfaces:
    BrokerPlugin, Broker

Direct Known Subclasses:
    MulticastTraceBrokerPlugin

A Broker interceptor which allows you to trace all operations to a UDP socket.
Field Summary
protected  WireFormat wireFormat     
protected  WireFormatFactory wireFormatFactory     
protected  int maxTraceDatagramSize     
protected  URI destination     
protected  DatagramSocket socket     
protected  BrokerId brokerId     
protected  SocketAddress address     
protected  boolean broadcast     
Fields inherited from org.apache.activemq.broker.MutableBrokerFilter:
next
Constructor:
 public UDPTraceBrokerPlugin() 
Method from org.apache.activemq.broker.util.UDPTraceBrokerPlugin Summary:
acknowledge,   addConnection,   addConsumer,   addDestinationInfo,   addProducer,   addSession,   beginTransaction,   commitTransaction,   createSocket,   createSocketAddress,   createWireFormat,   createWireFormatFactory,   forgetTransaction,   getAddress,   getDestination,   getMaxTraceDatagramSize,   getWireFormat,   getWireFormatFactory,   isBroadcast,   messagePull,   postProcessDispatch,   prepareTransaction,   processDispatchNotification,   removeConnection,   removeConsumer,   removeDestination,   removeDestinationInfo,   removeProducer,   removeSession,   removeSubscription,   rollbackTransaction,   send,   setAddress,   setBroadcast,   setDestination,   setMaxTraceDatagramSize,   setWireFormat,   setWireFormatFactory,   start,   stop
Methods from org.apache.activemq.broker.BrokerPluginSupport:
installPlugin
Methods from org.apache.activemq.broker.MutableBrokerFilter:
acknowledge,   addBroker,   addConnection,   addConsumer,   addDestination,   addDestinationInfo,   addProducer,   addSession,   beginTransaction,   brokerServiceStarted,   commitTransaction,   fastProducer,   forgetTransaction,   gc,   getAdaptor,   getAdminConnectionContext,   getBrokerId,   getBrokerName,   getBrokerSequenceId,   getBrokerService,   getClients,   getDestinationMap,   getDestinations,   getDestinations,   getDurableDestinations,   getNext,   getPeerBrokerInfos,   getPreparedTransactions,   getRoot,   getTempDataStore,   getVmConnectorURI,   isExpired,   isFaultTolerantConfiguration,   isFull,   isStopped,   messageConsumed,   messageDelivered,   messageDiscarded,   messageExpired,   messagePull,   nowMasterBroker,   postProcessDispatch,   preProcessDispatch,   prepareTransaction,   processDispatchNotification,   removeBroker,   removeConnection,   removeConsumer,   removeDestination,   removeDestinationInfo,   removeProducer,   removeSession,   removeSubscription,   rollbackTransaction,   send,   sendToDeadLetterQueue,   setAdminConnectionContext,   setNext,   slowConsumer,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.util.UDPTraceBrokerPlugin Detail:
 public  void acknowledge(ConsumerBrokerExchange consumerExchange,
    MessageAck ack) throws Exception 
 public  void addConnection(ConnectionContext context,
    ConnectionInfo info) throws Exception 
 public Subscription addConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void addDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void addProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void addSession(ConnectionContext context,
    SessionInfo info) throws Exception 
 public  void beginTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void commitTransaction(ConnectionContext context,
    TransactionId xid,
    boolean onePhase) throws Exception 
 protected DatagramSocket createSocket() throws IOException 
 protected SocketAddress createSocketAddress(URI location) throws UnknownHostException 
 protected WireFormat createWireFormat() 
 protected OpenWireFormatFactory createWireFormatFactory() 
 public  void forgetTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public SocketAddress getAddress() 
 public URI getDestination() 
 public int getMaxTraceDatagramSize() 
 public WireFormat getWireFormat() 
 public WireFormatFactory getWireFormatFactory() 
 public boolean isBroadcast() 
 public Response messagePull(ConnectionContext context,
    MessagePull pull) throws Exception 
 public  void postProcessDispatch(MessageDispatch messageDispatch) 
 public int prepareTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception 
 public  void removeConnection(ConnectionContext context,
    ConnectionInfo info,
    Throwable error) throws Exception 
 public  void removeConsumer(ConnectionContext context,
    ConsumerInfo info) throws Exception 
 public  void removeDestination(ConnectionContext context,
    ActiveMQDestination destination,
    long timeout) throws Exception 
 public  void removeDestinationInfo(ConnectionContext context,
    DestinationInfo info) throws Exception 
 public  void removeProducer(ConnectionContext context,
    ProducerInfo info) throws Exception 
 public  void removeSession(ConnectionContext context,
    SessionInfo info) throws Exception 
 public  void removeSubscription(ConnectionContext context,
    RemoveSubscriptionInfo info) throws Exception 
 public  void rollbackTransaction(ConnectionContext context,
    TransactionId xid) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message messageSend) throws Exception 
 public  void setAddress(SocketAddress address) 
 public  void setBroadcast(boolean broadcast) 
 public  void setDestination(URI destination) 
 public  void setMaxTraceDatagramSize(int maxTraceDatagramSize) 
 public  void setWireFormat(WireFormat wireFormat) 
 public  void setWireFormatFactory(WireFormatFactory wireFormatFactory) 
 public  void start() throws Exception 
 public  void stop() throws Exception