public class UdpMessageReceiver extends AbstractMessageReceiver implements javax.resource.spi.work.Work
UdpMessageReceiver
receives UDP message packets.Modifier and Type | Class and Description |
---|---|
protected class |
UdpMessageReceiver.UdpWorker |
Modifier and Type | Field and Description |
---|---|
protected int |
bufferSize |
protected AtomicBoolean |
disposing |
protected InetAddress |
inetAddress |
protected DatagramSocket |
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 |
---|
UdpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected DatagramPacket |
createPacket() |
protected DatagramSocket |
createSocket(URI uri,
InetAddress inetAddress) |
protected javax.resource.spi.work.Work |
createWork(DatagramPacket packet) |
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doStart() |
DatagramSocket |
getSocket()
Obtain the serverSocket
|
void |
release() |
void |
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, shouldConsumeInEveryNode, 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
protected DatagramSocket socket
protected InetAddress inetAddress
protected int bufferSize
protected final AtomicBoolean disposing
public UdpMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
protected void doStart() throws MuleException
doStart
in class AbstractTransportMessageHandler
MuleException
protected DatagramSocket createSocket(URI uri, InetAddress inetAddress) throws IOException
IOException
public DatagramSocket getSocket()
protected DatagramPacket createPacket()
public void release()
release
in interface javax.resource.spi.work.Work
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected javax.resource.spi.work.Work createWork(DatagramPacket packet) throws IOException
IOException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.