public class MulticastMessageReceiver extends UdpMessageReceiver
Modifier and Type | Class and Description |
---|---|
class |
MulticastMessageReceiver.MulticastWorker |
UdpMessageReceiver.UdpWorker
bufferSize, disposing, inetAddress, socket
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
MulticastMessageReceiver(AbstractConnector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected DatagramSocket |
createSocket(URI uri,
InetAddress inetAddress) |
protected javax.resource.spi.work.Work |
createWork(DatagramPacket packet) |
protected void |
doDispose() |
boolean |
shouldConsumeInEveryNode()
Determines whether to start or not the MessageSource base on the running node state.
|
createPacket, doConnect, doDisconnect, doStart, getSocket, release, run
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
public MulticastMessageReceiver(AbstractConnector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected DatagramSocket createSocket(URI uri, InetAddress inetAddress) throws IOException
createSocket
in class UdpMessageReceiver
IOException
protected javax.resource.spi.work.Work createWork(DatagramPacket packet) throws IOException
createWork
in class UdpMessageReceiver
IOException
protected void doDispose()
doDispose
in class UdpMessageReceiver
public boolean shouldConsumeInEveryNode()
AbstractMessageReceiver
shouldConsumeInEveryNode
in class AbstractMessageReceiver
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.