org.apache.activemq.broker.util: public class: MulticastTraceBrokerPlugin

org.apache.activemq.broker.util
public class: MulticastTraceBrokerPlugin [javadoc | source]

java.lang.Object
   org.apache.activemq.broker.MutableBrokerFilter
      org.apache.activemq.broker.BrokerPluginSupport
         org.apache.activemq.broker.util.UDPTraceBrokerPlugin
            org.apache.activemq.broker.util.MulticastTraceBrokerPlugin

All Implemented Interfaces:
BrokerPlugin, Broker

A Broker interceptor which allows you to trace all operations to a Multicast socket.

org.apache.xbean.XBean:

version: $ - Revision: 427613 $

Fields inherited from org.apache.activemq.broker.util.UDPTraceBrokerPlugin:
wireFormat, wireFormatFactory, maxTraceDatagramSize, destination, socket, brokerId, address, broadcast

Fields inherited from org.apache.activemq.broker.MutableBrokerFilter:
next

Constructor:
public MulticastTraceBrokerPlugin() { try { destination = new URI("multicast://224.1.2.3:61616"); } catch (URISyntaxException wontHappen) { } }

Constructor:

 public MulticastTraceBrokerPlugin() {
        try {
            destination = new URI("multicast://224.1.2.3:61616");
        } catch (URISyntaxException wontHappen) {
        }
}

Method from org.apache.activemq.broker.util.MulticastTraceBrokerPlugin Summary:
createSocket, getTimeToLive, setTimeToLive

Methods from org.apache.activemq.broker.util.UDPTraceBrokerPlugin:
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.util.UDPTraceBrokerPlugin:

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 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.MulticastTraceBrokerPlugin Detail:
protected DatagramSocket createSocket() throws IOException { MulticastSocket s = new MulticastSocket(); s.setSendBufferSize(maxTraceDatagramSize); s.setBroadcast(broadcast); s.setLoopbackMode(true); s.setTimeToLive(timeToLive); return s; }
public int getTimeToLive() { return timeToLive; }
public void setTimeToLive(int timeToLive) { this.timeToLive = timeToLive; }

Method from org.apache.activemq.broker.util.MulticastTraceBrokerPlugin Detail:

 protected DatagramSocket createSocket() throws IOException {
        MulticastSocket s = new MulticastSocket();
        s.setSendBufferSize(maxTraceDatagramSize);
        s.setBroadcast(broadcast);
        s.setLoopbackMode(true);
        s.setTimeToLive(timeToLive);
        return s;
}

 public int getTimeToLive() {
        return timeToLive;
}

 public  void setTimeToLive(int timeToLive) {
        this.timeToLive = timeToLive;
}