Class DynamicPipelineWorker
- java.lang.Object
-
- com.levigo.jadice.server.core.NodeWorker<DynamicPipelineNode>
-
- com.levigo.jadice.server.nodes.worker.DynamicPipelineWorker
-
- All Implemented Interfaces:
QualifiedLogEventReceiver
,WorkerController<DynamicPipelineNode>
,Runnable
public class DynamicPipelineWorker extends NodeWorker<DynamicPipelineNode>
The corresponding worker for theDynamicPipelineNode
.
-
-
Constructor Summary
Constructors Constructor Description DynamicPipelineWorker()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doAbortNow()
NodeWorker implementations can provide here own logic that shall be performed when an immediate abort is triggered.protected static boolean
matches(String contentType, String wantedMimeType)
protected static boolean
matches(javax.mail.internet.ContentType contentType, String wantedMimeType)
protected 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, doAbort, 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
protected void work() throws Throwable
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<DynamicPipelineNode>
- Throws:
Throwable
- in case of processing failure
-
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<DynamicPipelineNode>
-
matches
protected static final boolean matches(String contentType, String wantedMimeType) throws javax.mail.internet.ParseException
- Throws:
javax.mail.internet.ParseException
-
matches
protected static final boolean matches(javax.mail.internet.ContentType contentType, String wantedMimeType)
-
-