ome.smuggler.core.msg

Interface RepeatConsumer<T>

All Known Subinterfaces:

ImportFinaliser, ImportProcessor, MailProcessor

All Known Implementing Classes:

BatchCompletedHandler, BatchDisposalHandler, BatchUpdateHandler, Finaliser, ImportRunner, Mailer

public interface RepeatConsumer<T>

Plugs into a channel sink to consume its data and optionally request that the same data be delivered again. Use in conjunction with MessageRepeater or OnceOffSchedule and OnceOffRepeatConsumer.

Method Summary

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

Method Detail

consume

RepeatAction consume(T data)

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

Parameters:

data - 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.

Throws:

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