public class MulticastConnector extends UdpConnector
MulticastConnector
can dispatch mule events using ip multicastingModifier and Type | Field and Description |
---|---|
static String |
MULTICAST |
broadcast, DEFAULT_BUFFER_SIZE, DEFAULT_SOCKET_TIMEOUT, dispatcherSocketsPool, KEEP_SEND_SOCKET_OPEN_PROPERTY, keepSendSocketOpen, receiveBufferSize, receiveTimeout, sendBufferSize, sendTimeout, UDP
connected, connectedSemaphore, connecting, connectionStrategy, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
MulticastConnector() |
Modifier and Type | Method and Description |
---|---|
protected void |
doInitialise() |
String |
getProtocol() |
protected Object |
getReceiverKey(Service service,
InboundEndpoint endpoint)
The method determines the key used to store the receiver against.
|
int |
getTimeToLive() |
boolean |
isLoopback() |
void |
setLoopback(boolean loopback) |
void |
setTimeToLive(int timeToLive) |
doConnect, doDisconnect, doDispose, doStart, doStop, getReceiveBufferSize, getReceiveTimeout, getSendBufferSize, getSendTimeout, isBroadcast, isKeepSendSocketOpen, setBroadcast, setKeepSendSocketOpen, setReceiveBufferSize, setReceiveTimeout, setSendBufferSize, setSendTimeout
checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, exceptionThrown, fireNotification, getConnectedSemaphore, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMessageAdapter, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isStarted, isSyncEnabled, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnectionStrategy, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, workAccepted, workCompleted, workRejected, workStarted
public static final String MULTICAST
public String getProtocol()
getProtocol
in interface Connector
getProtocol
in class UdpConnector
protected void doInitialise() throws InitialisationException
doInitialise
in class UdpConnector
InitialisationException
public boolean isLoopback()
public void setLoopback(boolean loopback)
public int getTimeToLive()
public void setTimeToLive(int timeToLive)
protected Object getReceiverKey(Service service, InboundEndpoint endpoint)
AbstractConnector
getReceiverKey
in class UdpConnector
service
- the service for which the endpoint is being registeredendpoint
- the endpoint being registered for the serviceCopyright © 2003–2013 MuleSource, Inc.. All rights reserved.