com.levigo.jadice.server.documentplatform

Class ReshapeWorker

java.lang.Object

com.levigo.jadice.server.core.NodeWorker<ReshapeNode>

com.levigo.jadice.server.documentplatform.ReshapeWorker

All Implemented Interfaces:

WorkerController<ReshapeNode>, Runnable

public class ReshapeWorker
extends NodeWorker<ReshapeNode>

Constructor Summary

Constructors

Constructor and Description
ReshapeWorker()

Method Summary

Methods

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 Documents 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.

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, run, setDescriptor, setJob, toString, warn, warn, warn

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReshapeWorker

public ReshapeWorker()

Method Detail

preWork

protected void preWork()
                throws Throwable

Description copied from class: 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.

Overrides:

preWork in class NodeWorker<ReshapeNode>

Throws:

Throwable

See Also:

NodeWorker.initialize(), NodeWorker.work(), NodeWorker.postWork()

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 class NodeWorker<ReshapeNode>

Throws:

Throwable

postWork

protected void postWork()
                 throws Throwable

Description copied from class: 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.

Overrides:

postWork in class NodeWorker<ReshapeNode>

Throws:

Throwable

See Also:

NodeWorker.work(), NodeWorker.preWork()

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 class NodeWorker<ReshapeNode>

setDocumentProcessor

public void setDocumentProcessor(DocumentProcessor documentProcessor)

A DocumentProcessor that manipulates Documents can be injected here via Spring configuration.

Parameters:

documentProcessor - the DocumentProcessor to use

getDocumentProcessor

public DocumentProcessor getDocumentProcessor()

Returns:

a DocumentProcessor that can manipulate Documents before reshaping

getCurrentReader

public com.levigo.jadice.document.read.Reader getCurrentReader()

Returns:

The Reader instance which is currently in use.

setReshapeListener

public void setReshapeListener(ReshapeListener listener)