public class StreamOutputWorker extends NodeWorker<StreamOutputNode>
Constructor and Description |
---|
StreamOutputWorker() |
Modifier and Type | Method and Description |
---|---|
void |
abort()
Indicate that any current work should be aborted.
|
void |
initialize()
This method may be overridden, in order do perform initialization which is necessary before the
actual work is started.
|
void |
work()
Implement this method to let the node perform some useful work.
|
abortNow, addInputBundle, addOuputBundle, error, error, error, fail, fail, fail, getController, getInputBundle, getInputBundles, getJob, getLimitSupport, getNode, getOutputBundle, getOutputBundles, getServerJob, getStreamTransportFactory, getTransportSender, isAbortRequested, postWork, preWork, run, setDescriptor, setJob, warn, warn, warn
public void initialize() throws JobException
NodeWorker
initialize
in class NodeWorker<StreamOutputNode>
JobException
public void work() throws IOException, com.levigo.jadice.server.shared.transport.internal.TransportException, StreamTransportException, InterruptedException, ExecutionException
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<StreamOutputNode>
IOException
com.levigo.jadice.server.shared.transport.internal.TransportException
StreamTransportException
InterruptedException
ExecutionException
public void abort()
NodeWorker
abort
in class NodeWorker<StreamOutputNode>
Copyright © 2016 levigo holding gmbh. All rights reserved.