org.mule.extension.socket.api.connection.udp

Class UdpListenerConnection

java.lang.Object

org.mule.extension.socket.api.connection.AbstractSocketConnection

org.mule.extension.socket.api.connection.udp.AbstractUdpConnection

org.mule.extension.socket.api.connection.udp.UdpListenerConnection

All Implemented Interfaces:

ListenerConnection, SocketConnection

public class UdpListenerConnection
extends AbstractUdpConnection
implements ListenerConnection

Field Summary

Fields inherited from class org.mule.extension.socket.api.connection.udp.AbstractUdpConnection

objectSerializer, socket, socketProperties

Fields inherited from class org.mule.extension.socket.api.connection.AbstractSocketConnection

connectionSettings, LOGGER, wasDisconnected

Constructor Summary

Constructors

Constructor and Description
UdpListenerConnection(SocketConnectionSettings connectionSettings, UdpSocketProperties socketProperties)

Method Summary

Modifier and Type	Method and Description
void	connect() Establish a connection ready to be used.
SocketWorker	listen(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> sourceCallback) One worker is created per received package.

Methods inherited from class org.mule.extension.socket.api.connection.udp.AbstractUdpConnection

doDisconnect, newSocket, validate

Methods inherited from class org.mule.extension.socket.api.connection.AbstractSocketConnection

disconnect

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mule.extension.socket.api.connection.SocketConnection

disconnect, validate

Constructor Detail

UdpListenerConnection

public UdpListenerConnection(SocketConnectionSettings connectionSettings,
                             UdpSocketProperties socketProperties)
                      throws org.mule.runtime.api.connection.ConnectionException

Throws:

org.mule.runtime.api.connection.ConnectionException

Method Detail

connect

public void connect()
             throws org.mule.runtime.api.connection.ConnectionException

Description copied from interface: SocketConnection

Establish a connection ready to be used.

Specified by:

connect in interface SocketConnection

Throws:

org.mule.runtime.api.connection.ConnectionException - if the connection couldn't be established

listen

public SocketWorker listen(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> sourceCallback)
                    throws IOException,
                           org.mule.runtime.api.connection.ConnectionException

One worker is created per received package. If the other end of the connection is awaiting for a response, one will be sent but not from the same listener socket the source has. The response will be sent from a new different DatagramSocket bound to a port choose by the system.

The new DatagramSocket used for responding has the same configuration settings than the listener socket used in the Source.

Specified by:

listen in interface ListenerConnection

Parameters:

sourceCallback - used in the SocketWorker to deliver the new received messages

Returns:

a Runnable that will represent a new received connection. The Runnable should be scheduled with an Executor in it's own thread.

Throws:

ReadingTimeoutException - if the socket reached timeout while awaiting the arrival of a new package.

org.mule.runtime.api.connection.ConnectionException - if the socket was close while blocked on DatagramSocket.receive(DatagramPacket) method and the close was not intentionally done by the AbstractSocketConnection.disconnect() method.

IOException - if the socket was close while blocked on DatagramSocket.receive(DatagramPacket) method.