ome.smuggler.core.service.imports.impl

Class BatchCompletedHandler

java.lang.Object

ome.smuggler.core.service.imports.impl.BatchCompletedHandler

All Implemented Interfaces:

RepeatConsumer<ProcessedImport>, ImportFinaliser

public class BatchCompletedHandler
extends java.lang.Object
implements ImportFinaliser

Finalisation task to run when an import batch has completed, i.e. when all of its imports have completed.

Constructor Summary

Constructors

Constructor and Description
BatchCompletedHandler(ImportEnv env) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
RepeatAction	consume(ProcessedImport task) Consumes the message data and returns an indication of whether the same data should be delivered again.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchCompletedHandler

public BatchCompletedHandler(ImportEnv env)

Creates a new instance.

Parameters:

env - the import environment.

Throws:

java.lang.NullPointerException - if the argument is null.

Method Detail

consume

public RepeatAction consume(ProcessedImport task)

Description copied from interface: RepeatConsumer

Consumes the message data and returns an indication of whether the same data should be delivered again.

Specified by:

consume in interface RepeatConsumer<ProcessedImport>

Parameters:

task - the data received from the channel.

Returns:

either Repeat to indicate the data should be delivered again or Stop to indicate no further action should be taken.