Interface DocumentProcessor
-
- All Known Implementing Classes:
AsyncDocumentProcessor,AsyncNodeStateProcessor,CompositeDocumentProcessor,ConsistencyCheck,NodeCounter,OrphanedNodeCheck,Progress,ProgressWithETA,ReferenceCheck,Summary
public interface DocumentProcessorDefines an interface to processNodeDocuments.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default voidend(@NotNull BlockingQueue<Result> results)This method is called after the last document has been processed.static StringnowAsISO8601()voidprocessDocument(@NotNull NodeDocument document, @NotNull BlockingQueue<Result> results)Process the given document and publish the result to theresultsqueue.
-
-
-
Method Detail
-
processDocument
void processDocument(@NotNull @NotNull NodeDocument document, @NotNull @NotNull BlockingQueue<Result> results) throws InterruptedExceptionProcess the given document and publish the result to theresultsqueue. An implementation is not required to publish a result for each processed document.- Parameters:
document- the document to process.results- the queue to publish results if necessary.- Throws:
InterruptedException- if publishing a result is interrupted.
-
end
default void end(@NotNull @NotNull BlockingQueue<Result> results) throws InterruptedExceptionThis method is called after the last document has been processed. An implementation may wish to publish aggregated results at the end.- Parameters:
results- the queue to publish results if necessary.- Throws:
InterruptedException- if publishing a result is interrupted.
-
nowAsISO8601
static String nowAsISO8601()
- Returns:
- the current time as an ISO-8601 formatted string.
-
-