ome.smuggler.core.service.imports.impl

Class ImportRunner

java.lang.Object

ome.smuggler.core.service.imports.impl.ImportRunner

All Implemented Interfaces:

RepeatConsumer<QueuedImport>, ImportProcessor

public class ImportRunner
extends java.lang.Object
implements ImportProcessor

Implements the ImportProcessor.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
RepeatAction	consume(QueuedImport 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

ImportRunner

public ImportRunner(ImportEnv env)

Creates a new instance.

Parameters:

env - the import environment.

Method Detail

consume

public RepeatAction consume(QueuedImport 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<QueuedImport>

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.