com.amazonaws.services.cloudtrail.processinglibrary.reader

Class EventReader

java.lang.Object

com.amazonaws.services.cloudtrail.processinglibrary.reader.EventReader

public class EventReader
extends java.lang.Object

EventReader is responsible for processing a stream of events. It parses each event and hands the events to EventsProcessor to process.

Constructor Summary

Constructors

Constructor and Description
EventReader(EventsProcessor eventsProcessor, SourceFilter sourceFilter, EventFilter eventFilter, ProgressReporter progressReporter, ExceptionHandler exceptionHandler, SqsManager sqsManager, S3Manager s3Manager, ProcessingConfiguration configuration) Internal use only.

Method Summary

Modifier and Type	Method and Description
java.util.List<CloudTrailSource>	getSources() Poll messages from SQS queue and convert messages to CloudTrailSource.
void	processSource(CloudTrailSource source) Retrieve S3 object URL from source then downloads the object processes each event through call back functions.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventReader

public EventReader(EventsProcessor eventsProcessor,
                   SourceFilter sourceFilter,
                   EventFilter eventFilter,
                   ProgressReporter progressReporter,
                   ExceptionHandler exceptionHandler,
                   SqsManager sqsManager,
                   S3Manager s3Manager,
                   ProcessingConfiguration configuration)

Internal use only. This constructor creates an instance of EventReader object.

Parameters:

eventsProcessor - user's implementation of eventsProcessor.

sourceFilter - user's implementation of sourceFilter.

eventFilter - user's implementation of eventFilter.

progressReporter - user's implementation of progressReporter.

exceptionHandler - user's implementation of exceptionHandler.

sqsManager - that poll message from SQS queue.

s3Manager - that download CloudTrail log files from S3.

configuration - user provided ProcessingConfiguration.

Method Detail

getSources

public java.util.List<CloudTrailSource> getSources()

Poll messages from SQS queue and convert messages to CloudTrailSource.

Returns:

a list of CloudTrailSource.

processSource

public void processSource(CloudTrailSource source)

Retrieve S3 object URL from source then downloads the object processes each event through call back functions.

Parameters:

source - CloudTrailSource to process.