org.mule.providers.udp
Class UdpMessageReceiver
java.lang.Object
org.mule.providers.AbstractMessageReceiver
org.mule.providers.udp.UdpMessageReceiver
- All Implemented Interfaces:
- Disposable, java.lang.Runnable, UMOMessageReceiver
- Direct Known Subclasses:
- MulticastMessageReceiver
- public class UdpMessageReceiver
- extends AbstractMessageReceiver
- implements java.lang.Runnable
UdpMessageReceiver
TODO (document class)
- Version:
- $Revision: 1.2 $
- Author:
- Ross Mason
Method Summary |
protected void |
connect(java.net.URI uri)
|
protected java.net.DatagramPacket |
createPacket()
|
protected java.net.DatagramSocket |
createSocket(java.net.URI uri,
java.net.InetAddress inetAddress)
|
protected java.lang.Runnable |
createWorker(java.net.DatagramPacket packet)
|
void |
doDispose()
Template method to dispose any resources associated with this receiver. |
java.net.DatagramSocket |
getSocket()
Obtain the serverSocket |
void |
run()
|
Methods inherited from class org.mule.providers.AbstractMessageReceiver |
allowFilter, create, dispose, getComponent, getConnector, getEndpoint, getEndpointURI, handleException, handleSecurtyException, handleUnacceptedFilter, isServerSide, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setServerSide |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
socket
protected java.net.DatagramSocket socket
threadPool
protected PooledExecutor threadPool
inetAddress
protected java.net.InetAddress inetAddress
bufferSize
protected int bufferSize
UdpMessageReceiver
public UdpMessageReceiver(AbstractConnector connector,
UMOComponent component,
UMOEndpoint endpoint)
throws InitialisationException
connect
protected void connect(java.net.URI uri)
throws InitialisationException
- Throws:
InitialisationException
createSocket
protected java.net.DatagramSocket createSocket(java.net.URI uri,
java.net.InetAddress inetAddress)
throws java.io.IOException
- Throws:
java.io.IOException
getSocket
public java.net.DatagramSocket getSocket()
- Obtain the serverSocket
createPacket
protected java.net.DatagramPacket createPacket()
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
doDispose
public void doDispose()
throws UMOException
- Description copied from class:
AbstractMessageReceiver
- Template method to dispose any resources associated with this receiver. There
is not need to dispose the connector as this is already done by the framework
- Overrides:
doDispose
in class AbstractMessageReceiver
- Throws:
UMOException
createWorker
protected java.lang.Runnable createWorker(java.net.DatagramPacket packet)
throws java.io.IOException
- Throws:
java.io.IOException
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.