org.mule.extension.socket.api.connection

Interface ListenerConnection

All Superinterfaces:

SocketConnection

All Known Implementing Classes:

TcpListenerConnection, UdpListenerConnection

public interface ListenerConnection
extends SocketConnection

This kind of SocketConnection enables the SocketListener to await for new incoming connections and wraps each one of those into a SocketWorker so they can run independently in their own thread.

Since:

4.0

Method Summary

Modifier and Type	Method and Description
SocketWorker	listen(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> sourceCallback) This method blocks until a new connection is received or timeout exception is thrown.

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

connect, disconnect, validate

Method Detail

listen

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

This method blocks until a new connection is received or timeout exception is thrown.

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:

IOException - if the connection was suddenly closed

org.mule.runtime.api.connection.ConnectionException - if the connection was closed and the cause was the invocation of SocketConnection.disconnect()