protected static interface InputModule.ModuleInput extends ForwarderModule.Abstract.ModuleInputOutput
Modifier and Type | Method and Description |
---|---|
String |
getSourceName()
Gets the source's name.
|
Optional<Serializable[]> |
input(BatchControl batchControl)
Inputs messages.
|
boolean |
rollback()
Rolls back.
|
close, commit, getDisplayName, isClosed, isReliable, open, setUp, tearDown
@Nonnull @CheckReturnValue String getSourceName()
@Nonnull @CheckReturnValue Optional<Serializable[]> input(@Nonnull BatchControl batchControl) throws InterruptedException
batchControl
- The batch control.InterruptedException
- When the service is stopped.@CheckReturnValue boolean rollback()
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.