Class StreamInputWorker
- java.lang.Object
-
- com.levigo.jadice.server.core.NodeWorker<StreamInputNode>
-
- com.levigo.jadice.server.nodes.worker.StreamInputWorker
-
- All Implemented Interfaces:
QualifiedLogEventReceiver
,WorkerController<StreamInputNode>
,Runnable
public class StreamInputWorker extends NodeWorker<StreamInputNode>
-
-
Constructor Summary
Constructors Constructor Description StreamInputWorker()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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
-
-
-
-
Method Detail
-
work
public void work() throws IOException
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 classNodeWorker<StreamInputNode>
- Throws:
IOException
-
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 classNodeWorker<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 classNodeWorker<StreamInputNode>
-
-