public class ReshapeWorker extends NodeWorker<ReshapeNode>
Constructor and Description |
---|
ReshapeWorker() |
Modifier and Type | Method and Description |
---|---|
protected void |
doAbortNow()
NodeWorker implementations can provide here own logic that shall be
performed when an immediate abort is triggered.
|
com.levigo.jadice.document.read.Reader |
getCurrentReader() |
DocumentProcessor |
getDocumentProcessor() |
protected void |
postWork()
This method is called immediately after
NodeWorker.work() has returned. |
protected void |
preWork()
This method is called immediately before
NodeWorker.work() will be called. |
void |
setDocumentProcessor(DocumentProcessor documentProcessor)
A
DocumentProcessor that manipulates Document s can be injected here via Spring
configuration. |
void |
setReshapeListener(ReshapeListener listener) |
protected void |
work()
Implement this method to let the node perform some useful work.
|
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, 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<ReshapeNode>
Throwable
NodeWorker.initialize()
,
#work()}
,
NodeWorker.postWork()
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<ReshapeNode>
Throwable
protected void postWork() throws Throwable
NodeWorker
This method is called immediately after NodeWorker.work()
has returned. It will be called even
when a failure in NodeWorker.work()
has occured.
Use this method e.g. to finalize objects on the same Thread
on which NodeWorker.work()
is
executed.
postWork
in class NodeWorker<ReshapeNode>
Throwable
NodeWorker.work()
,
NodeWorker.preWork()
protected void doAbortNow()
NodeWorker
doAbortNow
in class NodeWorker<ReshapeNode>
public void setDocumentProcessor(DocumentProcessor documentProcessor)
DocumentProcessor
that manipulates Document
s can be injected here via Spring
configuration.documentProcessor
- the DocumentProcessor
to usepublic DocumentProcessor getDocumentProcessor()
DocumentProcessor
that can manipulate Document
s before reshapingpublic com.levigo.jadice.document.read.Reader getCurrentReader()
Reader
instance which is currently in use.public void setReshapeListener(ReshapeListener listener)
Copyright © 2017 levigo holding gmbh. All rights reserved.