ome.smuggler.core.service.imports.impl

Class BatchDisposalHandler

java.lang.Object

ome.smuggler.core.service.imports.impl.BatchDisposalHandler

All Implemented Interfaces:

RepeatConsumer<ProcessedImport>, ImportFinaliser

public class BatchDisposalHandler
extends java.lang.Object
implements ImportFinaliser

Finalisation task to run after batch completion to get rid of any resources still associated with the batch, such as import logs and the batch store file.

Constructor Summary

Constructors

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

BatchDisposalHandler

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