public class MulticastConnector extends UdpConnector
MulticastConnector
can dispatch mule events using ip multicastingModifier and Type | Field and Description |
---|---|
static String |
MULTICAST |
ADDRESS_PROPERTY, broadcast, DEFAULT_BUFFER_SIZE, DEFAULT_SOCKET_TIMEOUT, dispatcherSocketsPool, KEEP_SEND_SOCKET_OPEN_PROPERTY, keepSendSocketOpen, PORT_PROPERTY, receiveBufferSize, sendBufferSize, socketFactory, timeout, UDP
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
Constructor and Description |
---|
MulticastConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
doInitialise() |
String |
getProtocol() |
protected Object |
getReceiverKey(FlowConstruct flowConstruct,
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, getSendBufferSize, getTimeout, isBroadcast, isKeepSendSocketOpen, setBroadcast, setKeepSendSocketOpen, setReceiveBufferSize, setSendBufferSize, setTimeout
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getCanonicalURI, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOperationResourceFactory, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, returnDispatcher, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
public static final String MULTICAST
public MulticastConnector(MuleContext context)
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(FlowConstruct flowConstruct, InboundEndpoint endpoint)
AbstractConnector
getReceiverKey
in class UdpConnector
flowConstruct
- the service for which the endpoint is being registeredendpoint
- the endpoint being registered for the serviceCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.