org.mule.extension.socket.api.worker

Class SocketWorker

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

TcpWorker, UdpWorker

public abstract class SocketWorker
extends Object
implements org.mule.runtime.api.lifecycle.Disposable, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes>	callback
protected String	encoding

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

PHASE_NAME

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SocketWorker(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback)

Method Summary

Modifier and Type	Method and Description
protected abstract void	doRun()
protected void	handle(InputStream content, SocketAttributes attributes)
abstract void	onComplete(Object result)
void	onError(Consumer<Exception> handler)
abstract void	onError(Throwable e)
void	run()
void	setEncoding(String encoding)

Methods inherited from class java.lang.Object

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

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

dispose

Field Detail

callback

protected final org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback

encoding

protected String encoding

Constructor Detail

SocketWorker

protected SocketWorker(org.mule.runtime.extension.api.runtime.source.SourceCallback<InputStream,SocketAttributes> callback)

Method Detail

setEncoding

public void setEncoding(String encoding)

onError

public void onError(Consumer<Exception> handler)

run

public final void run()

Specified by:

run in interface Runnable

doRun

protected abstract void doRun()
                       throws Exception

Throws:

Exception

handle

protected void handle(InputStream content,
                      SocketAttributes attributes)

onComplete

public abstract void onComplete(Object result)

onError

public abstract void onError(Throwable e)