ome.smuggler.core.service.imports.impl

Class BatchUpdateHandler

java.lang.Object

ome.smuggler.core.service.imports.impl.BatchUpdateHandler

All Implemented Interfaces:

RepeatConsumer<ProcessedImport>, ImportFinaliser

public class BatchUpdateHandler
extends java.lang.Object
implements ImportFinaliser

Finalisation task to update an import batch to reflect one of its imports has completed.

Constructor Summary

Constructors

Constructor and Description
BatchUpdateHandler(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

BatchUpdateHandler

public BatchUpdateHandler(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.