org.rvpf.forwarder.input

Interface InputModule.ModuleInput

All Superinterfaces:

ForwarderModule.Abstract.ModuleInputOutput

All Known Implementing Classes:

InputModule.AbstractInput

Enclosing class:

InputModule

protected static interface InputModule.ModuleInput
extends ForwarderModule.Abstract.ModuleInputOutput

Module input.

Method Summary

Modifier and Type	Method and Description
String	getSourceName() Gets the source's name.
Optional<Serializable[]>	input(BatchControl batchControl) Inputs messages.
boolean	rollback() Rolls back.

Methods inherited from interface ForwarderModule.Abstract.ModuleInputOutput

close, commit, getDisplayName, isClosed, isReliable, open, setUp, tearDown

Method Detail

getSourceName

@Nonnull
 @CheckReturnValue
String getSourceName()

Gets the source's name.

Returns:

The source's name.

input

@Nonnull
 @CheckReturnValue
Optional<Serializable[]> input(@Nonnull
                                                             BatchControl batchControl)
                                                      throws InterruptedException

Inputs messages.

Parameters:

batchControl - The batch control.

Returns:

The optional messages.

Throws:

InterruptedException - When the service is stopped.

rollback

@CheckReturnValue
boolean rollback()

Rolls back.

Returns:

True on success.