public class DynamicPipelineWorker extends NodeWorker<DynamicPipelineNode>
DynamicPipelineNode
.Constructor and Description |
---|
DynamicPipelineWorker() |
Modifier and Type | Method and Description |
---|---|
void |
abortNow()
Indicate that any current work should be aborted ASAP.
|
protected static boolean |
matches(javax.mail.internet.ContentType contentType,
String wantedMimeType) |
protected static boolean |
matches(String contentType,
String wantedMimeType) |
protected void |
work()
Implement this method to let the node perform some useful work.
|
abort, addInputBundle, addOuputBundle, error, error, error, fail, fail, fail, getController, getInputBundle, getInputBundles, getJob, getLimitSupport, getNode, getOutputBundle, getOutputBundles, getServerJob, getStreamTransportFactory, getTransportSender, initialize, isAbortRequested, postWork, preWork, run, setDescriptor, setJob, warn, warn, warn
protected void work() throws Throwable
NodeWorker
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.
work
in class NodeWorker<DynamicPipelineNode>
Throwable
public void abortNow()
NodeWorker
abortNow
in class NodeWorker<DynamicPipelineNode>
protected static final boolean matches(String contentType, String wantedMimeType) throws javax.mail.internet.ParseException
javax.mail.internet.ParseException
protected static final boolean matches(javax.mail.internet.ContentType contentType, String wantedMimeType)
Copyright © 2016 levigo holding gmbh. All rights reserved.