public class MulticastTraceBrokerPlugin extends UDPTraceBrokerPlugin
address, broadcast, brokerId, destination, maxTraceDatagramSize, socket, wireFormat, wireFormatFactory
next
Constructor and Description |
---|
MulticastTraceBrokerPlugin() |
Modifier and Type | Method and Description |
---|---|
protected DatagramSocket |
createSocket() |
int |
getTimeToLive() |
void |
setTimeToLive(int timeToLive) |
acknowledge, addConnection, addConsumer, addDestinationInfo, addProducer, addSession, beginTransaction, commitTransaction, 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
installPlugin
addBroker, addDestination, brokerServiceStarted, fastProducer, 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, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, preProcessDispatch, processConsumerControl, reapplyInterceptor, removeBroker, sendToDeadLetterQueue, setAdminConnectionContext, setNext, slowConsumer, virtualDestinationAdded, virtualDestinationRemoved
public MulticastTraceBrokerPlugin()
protected DatagramSocket createSocket() throws IOException
createSocket
in class UDPTraceBrokerPlugin
IOException
public int getTimeToLive()
public void setTimeToLive(int timeToLive)
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.