Package org.apache.jackrabbit.oak.plugins.document.check

Class CompositeDocumentProcessor

java.lang.Object

org.apache.jackrabbit.oak.plugins.document.check.CompositeDocumentProcessor

All Implemented Interfaces:

DocumentProcessor

public class CompositeDocumentProcessor
extends Object
implements DocumentProcessor

CompositeDocumentProcessor...

Method Summary

Modifier and Type	Method	Description
static DocumentProcessor	compose(Iterable<DocumentProcessor> processors)
void	end(@NotNull BlockingQueue<Result> results)	This method is called after the last document has been processed.
void	processDocument(@NotNull NodeDocument document, @NotNull BlockingQueue<Result> results)	Process the given document and publish the result to the results queue.

Methods inherited from class java.lang.Object

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

Method Detail

compose

public static DocumentProcessor compose(Iterable<DocumentProcessor> processors)

processDocument

public void processDocument(@NotNull
                            @NotNull NodeDocument document,
                            @NotNull
                            @NotNull BlockingQueue<Result> results)
                     throws InterruptedException

Description copied from interface: DocumentProcessor

Process the given document and publish the result to the results queue. An implementation is not required to publish a result for each processed document.

Specified by:

processDocument in interface DocumentProcessor

Parameters:

document - the document to process.

results - the queue to publish results if necessary.

Throws:

InterruptedException - if publishing a result is interrupted.

end

public void end(@NotNull
                @NotNull BlockingQueue<Result> results)
         throws InterruptedException

Description copied from interface: DocumentProcessor

This method is called after the last document has been processed. An implementation may wish to publish aggregated results at the end.

Specified by:

end in interface DocumentProcessor

Parameters:

results - the queue to publish results if necessary.

Throws:

InterruptedException - if publishing a result is interrupted.