public final class SOMReceiverModule extends InputModule
InputModule.AbstractInput, InputModule.ModuleInput
ForwarderModule.Abstract.AbstractInputOutput, ForwarderModule.Abstract.ModuleInputOutput
ForwarderModule.Abstract
Modifier and Type | Field and Description |
---|---|
static String |
QUEUE_PROPERTIES
The queue properties.
|
Constructor and Description |
---|
SOMReceiverModule() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
setUp(KeyedGroups moduleProperties)
Sets up this module.
|
getDefaultBatchLimit, getInput, output, run, setInput, start, stop, tearDown
filter, getBatchControl, getConfig, getConfigProperties, getConnectionRetryDelay, getDefaultBatchWait, getForwarderAppImpl, getMetadata, getReliable, getService, getThisLogger, getTraces, isReliable, loadMetadata, needsMetadata, onMetadataRefreshed, setReliable, setUp
public static final String QUEUE_PROPERTIES
protected boolean setUp(KeyedGroups moduleProperties)
setUp
in class InputModule
moduleProperties
- The module properties.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.