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 InetAddress |
inetAddress |
protected List |
responseTransformers |
protected DatagramSocket |
socket |
connected, connecting, connectionStrategy, connector, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
UdpMessageReceiver(Connector connector,
Service service,
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() |
protected void |
doStop() |
protected List |
getResponseTransformers() |
DatagramSocket |
getSocket()
Obtain the serverSocket
|
void |
release() |
void |
run() |
connect, disconnect, dispose, doInitialise, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getReceiverKey, getService, getWorkManager, handleException, handleUnacceptedFilter, initialise, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setConnector, setEndpoint, setExceptionDetails, setListener, setReceiverKey, setService, setWorkManager, start, stop, toString
protected DatagramSocket socket
protected InetAddress inetAddress
protected int bufferSize
protected List responseTransformers
public UdpMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doConnect() throws Exception
doConnect
in class AbstractMessageReceiver
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractMessageReceiver
Exception
protected void doStart() throws MuleException
doStart
in class AbstractMessageReceiver
MuleException
protected void doStop() throws MuleException
doStop
in class AbstractMessageReceiver
MuleException
protected List getResponseTransformers()
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–2013 MuleSource, Inc.. All rights reserved.