public class UnZIPWorker extends StreamWorker<UnZIPNode>
UnZIPNode
.Constructor and Description |
---|
UnZIPWorker() |
Modifier and Type | Method and Description |
---|---|
protected void |
preWork()
This method is called immediately before
NodeWorker.work() will be called. |
protected void |
work(Stream stream)
Implement this method in order to work on a single stream.
|
accept, reject, work
abort, abortNow, addInputBundle, addOutputBundle, doAbort, doAbortNow, error, error, error, fail, fail, fail, getController, getInputBundle, getInputBundles, getJob, getLimitSupport, getNode, getOutputBundle, getOutputBundles, getServerJob, getState, getStreamTransportFactory, getTransportSender, initialize, isAbortRequested, postWork, run, setDescriptor, setJob, toString, warn, warn, warn
protected void preWork() throws Throwable
NodeWorker
This method is called immediately before NodeWorker.work()
will be called.
Use this method e.g. to initialize objects on the same Thread
on which NodeWorker.work()
is executed in contrast to NodeWorker.initialize()
which is called on a different Thread
.
preWork
in class NodeWorker<UnZIPNode>
Throwable
NodeWorker.initialize()
,
#work()}
,
NodeWorker.postWork()
protected void work(Stream stream) throws Throwable
StreamWorker
work
in class StreamWorker<UnZIPNode>
Throwable
Copyright © 2017 levigo holding gmbh. All rights reserved.