public class AWSCloudTrailProcessingExecutor
extends java.lang.Object
EventReaderFactory
object which spawns a EventReader
to process log files.
It has two thread pools: scheduledThreadPool
, which is a single-threaded scheduled
thread pool used to poll SQS for messages, and mainThreadPool
, which has a
configurable size and processes each CloudTrailSource
in parallel.
Modifier and Type | Class and Description |
---|---|
static class |
AWSCloudTrailProcessingExecutor.Builder
A class that builds an
AWSCloudTrailProcessingExecutor object. |
Modifier and Type | Method and Description |
---|---|
void |
start()
Start processing AWS CloudTrail logs.
|
void |
stop()
Stop processing AWS CloudTrail logs.
|