org.mule.extension.socket.api.worker

Class TcpWorker

java.lang.Object

org.mule.extension.socket.api.worker.SocketWorker

org.mule.extension.socket.api.worker.TcpWorker

All Implemented Interfaces:

Runnable, org.mule.runtime.api.lifecycle.Disposable

public final class TcpWorker
extends SocketWorker

Only one worker will be created per each new TCP connection accepted by the TcpListenerConnection.listen(SourceCallback), This class is responsible for reading from that connection is closed by the sender, or Source is stopped.

Since:

4.0

Field Summary

Fields inherited from class org.mule.extension.socket.api.worker.SocketWorker

callback, encoding

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
TcpWorker(Socket socket, TcpProtocol protocol, org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback)

Method Summary

Modifier and Type	Method and Description
void	dispose()
void	doRun()
void	onComplete(Object result)
void	onError(Throwable e)
protected void	shutdownSocket()

Methods inherited from class org.mule.extension.socket.api.worker.SocketWorker

handle, onError, run, setEncoding

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpWorker

public TcpWorker(Socket socket,
                 TcpProtocol protocol,
                 org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback)
          throws IOException

Throws:

IOException

Method Detail

shutdownSocket

protected void shutdownSocket()
                       throws IOException

Throws:

IOException

doRun

public void doRun()

Specified by:

doRun in class SocketWorker

onComplete

public void onComplete(Object result)

Specified by:

onComplete in class SocketWorker

onError

public void onError(Throwable e)

Specified by:

onError in class SocketWorker

dispose

public void dispose()