com.levigo.jadice.server.nodes.worker

Class StreamInputWorker

java.lang.Object

com.levigo.jadice.server.core.NodeWorker<StreamInputNode>

com.levigo.jadice.server.nodes.worker.StreamInputWorker

All Implemented Interfaces:

WorkerController<StreamInputNode>, Runnable

public class StreamInputWorker
extends NodeWorker<StreamInputNode>

Constructor Summary

Constructors

Constructor and Description
StreamInputWorker()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doAbort() NodeWorker implementations can provide here own logic that shall be performed when an abort is triggered.
protected void	doAbortNow() NodeWorker implementations can provide here own logic that shall be performed when an immediate abort is triggered.
void	work() Implement this method to let the node perform some useful work.

Methods inherited from class com.levigo.jadice.server.core.NodeWorker

abort, abortNow, addInputBundle, addOutputBundle, error, error, error, fail, fail, fail, getController, getInputBundle, getInputBundles, getJob, getLimitSupport, getNode, getOutputBundle, getOutputBundles, getServerJob, getState, getStreamTransportFactory, getTransportSender, initialize, isAbortRequested, postWork, preWork, run, setDescriptor, setJob, toString, warn, warn, warn

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamInputWorker

public StreamInputWorker()

Method Detail

work

public void work()
          throws IOException,
                 com.levigo.jadice.server.shared.transport.internal.TransportException

Description copied from class: NodeWorker

Implement this method to let the node perform some useful work.

Implementors are free to throw whatever exception they see fit. If any Throwable is thrown from this method, the failure manager is notified about the fatal failure of the whole pipeline.

Specified by:

work in class NodeWorker<StreamInputNode>

Throws:

IOException

com.levigo.jadice.server.shared.transport.internal.TransportException

doAbort

protected void doAbort()

Description copied from class: NodeWorker

NodeWorker implementations can provide here own logic that shall be performed when an abort is triggered.

Overrides:

doAbort in class NodeWorker<StreamInputNode>

doAbortNow

protected void doAbortNow()

Description copied from class: NodeWorker

NodeWorker implementations can provide here own logic that shall be performed when an immediate abort is triggered. jadice server 5.5.0.0

Overrides:

doAbortNow in class NodeWorker<StreamInputNode>