public final class MessagesFilesModule extends InputModule
InputModule.AbstractInput, InputModule.ModuleInput
ForwarderModule.Abstract.AbstractInputOutput, ForwarderModule.Abstract.ModuleInputOutput
ForwarderModule.Abstract
Modifier and Type | Field and Description |
---|---|
static String |
COMPRESSED_SUFFIX_PROPERTY
The file name suffix for compressed input files.
|
static String |
DATA_PREFIX_PROPERTY
The file prefix for data entries.
|
static String |
DATA_SUFFIX_PROPERTY
The file suffix for data entries.
|
static String |
DEFAULT_COMPRESSED_SUFFIX
Default compressed file suffix.
|
static String |
DEFAULT_DATA_SUFFIX
Default file suffix for data entries.
|
static String |
DEFAULT_DONE_SUFFIX
Default file suffix for done entries.
|
static ElapsedTime |
DEFAULT_SCAN_INTERVAL
Default input directory scan interval.
|
static String |
DONE_PREFIX_PROPERTY
The file prefix for data entries.
|
static String |
DONE_SUFFIX_PROPERTY
The file suffix for done entries.
|
static String |
INPUT_DIR_PROPERTY
The module's input directory.
|
static String |
SCAN_INTERVAL_PROPERTY
The time in millis between scans of the input directory.
|
static String |
SEM_DIR_PROPERTY
Semaphore directory property.
|
static String |
SEM_MATCH_ENABLED_PROPERTY
Semaphore files match enabled property.
|
static String |
SEM_PREFIX_PROPERTY
Semaphore file name prefix property.
|
static String |
SEM_PURGE_ENABLED_PROPERTY
Semaphore files purge enabled property.
|
static String |
SEM_SUFFIX_PROPERTY
The file suffix for semaphore entries.
|
Constructor and Description |
---|
MessagesFilesModule() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
setUp(KeyedGroups moduleProperties)
Sets up this module.
|
void |
start()
Starts this module.
|
void |
stop()
Stops this module.
|
void |
tearDown()
Tears down what has been set up.
|
getDefaultBatchLimit, getInput, output, run, setInput
filter, getBatchControl, getConfig, getConfigProperties, getConnectionRetryDelay, getDefaultBatchWait, getForwarderAppImpl, getMetadata, getReliable, getService, getThisLogger, getTraces, isReliable, loadMetadata, needsMetadata, onMetadataRefreshed, setReliable, setUp
public static final String COMPRESSED_SUFFIX_PROPERTY
public static final String DATA_PREFIX_PROPERTY
public static final String DATA_SUFFIX_PROPERTY
public static final String DEFAULT_COMPRESSED_SUFFIX
public static final String DEFAULT_DATA_SUFFIX
public static final String DEFAULT_DONE_SUFFIX
public static final ElapsedTime DEFAULT_SCAN_INTERVAL
public static final String DONE_PREFIX_PROPERTY
public static final String DONE_SUFFIX_PROPERTY
public static final String INPUT_DIR_PROPERTY
public static final String SCAN_INTERVAL_PROPERTY
public static final String SEM_DIR_PROPERTY
public static final String SEM_MATCH_ENABLED_PROPERTY
public static final String SEM_PREFIX_PROPERTY
public static final String SEM_PURGE_ENABLED_PROPERTY
public static final String SEM_SUFFIX_PROPERTY
public void start()
start
in interface ForwarderModule
start
in class InputModule
public void stop()
stop
in interface ForwarderModule
stop
in class InputModule
public void tearDown()
tearDown
in interface ForwarderModule
tearDown
in class InputModule
protected boolean setUp(KeyedGroups moduleProperties)
setUp
in class InputModule
moduleProperties
- The module properties.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.