org.mule.providers.udp
Class UdpMessageDispatcher
java.lang.Object
org.mule.providers.AbstractMessageDispatcher
org.mule.providers.udp.UdpMessageDispatcher
- All Implemented Interfaces:
- Disposable, java.beans.ExceptionListener, UMOMessageDispatcher
- Direct Known Subclasses:
- MulticastMessageDispatcher
- public class UdpMessageDispatcher
- extends AbstractMessageDispatcher
UdpMessageDispatcher
TODO
- Version:
- $Revision: 1.1.1.1 $
- Author:
- Ross Mason
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connector
protected UdpConnector connector
inetAddress
protected java.net.InetAddress inetAddress
socket
protected java.net.DatagramSocket socket
port
protected int port
initialised
protected SynchronizedBoolean initialised
UdpMessageDispatcher
public UdpMessageDispatcher(UdpConnector connector)
createSocket
protected java.net.DatagramSocket createSocket(int port,
java.net.InetAddress inetAddress)
throws java.io.IOException
- Throws:
java.io.IOException
initialise
protected void initialise(java.lang.String endpoint)
throws java.io.IOException,
java.net.URISyntaxException
- Throws:
java.io.IOException
java.net.URISyntaxException
doDispatch
public void doDispatch(UMOEvent event)
throws java.lang.Exception
- Specified by:
doDispatch
in class AbstractMessageDispatcher
- Throws:
java.lang.Exception
write
protected void write(java.net.DatagramSocket socket,
byte[] data)
throws java.io.IOException
- Throws:
java.io.IOException
doSend
public UMOMessage doSend(UMOEvent event)
throws java.lang.Exception
- Specified by:
doSend
in class AbstractMessageDispatcher
- Throws:
java.lang.Exception
receive
public UMOMessage receive(UMOEndpointURI endpointUri,
long timeout)
throws java.lang.Exception
- Throws:
java.lang.Exception
getDelegateSession
public java.lang.Object getDelegateSession()
throws UMOException
- Throws:
UMOException
getConnector
public UMOConnector getConnector()
- Specified by:
getConnector
in interface UMOMessageDispatcher
- Overrides:
getConnector
in class AbstractMessageDispatcher
doDispose
public void doDispose()
throws UMOException
- Specified by:
doDispose
in class AbstractMessageDispatcher
- Throws:
UMOException
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.