com.amazonaws.services.cloudtrail.processinglibrary.serializer

Class S3SourceSerializer

java.lang.Object

com.amazonaws.services.cloudtrail.processinglibrary.serializer.S3SourceSerializer

All Implemented Interfaces:

SourceSerializer

public class S3SourceSerializer
extends java.lang.Object
implements SourceSerializer

The S3SourceSerializer extracts CloudTrail log file information from notifications sent directly by Amazon S3. Use SourceSerializerFactory.createS3SourceSerializer() for initialization.

Constructor Summary

Constructors

Constructor and Description
S3SourceSerializer(ObjectMapper mapper, SourceIdentifier sourceIdentifier)

Method Summary

Modifier and Type	Method and Description
CloudTrailSource	getCloudTrailSource(Message sqsMessage, JsonNode s3MessageNode)
CloudTrailSource	getSource(Message sqsMessage) Get CloudTrail log file information by parsing single SQS message.

Methods inherited from class java.lang.Object

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

Constructor Detail

S3SourceSerializer

public S3SourceSerializer(ObjectMapper mapper,
                          SourceIdentifier sourceIdentifier)

Method Detail

getSource

public CloudTrailSource getSource(Message sqsMessage)
                           throws java.io.IOException

Description copied from interface: SourceSerializer

Get CloudTrail log file information by parsing single SQS message.

Specified by:

getSource in interface SourceSerializer

Parameters:

sqsMessage - The message polled from SQS queue.

Returns:

CloudTrailSource that contains log file information.

Throws:

java.io.IOException - If sqsMessage is unrecognized.

getCloudTrailSource

public CloudTrailSource getCloudTrailSource(Message sqsMessage,
                                            JsonNode s3MessageNode)
                                     throws java.io.IOException

Throws:

java.io.IOException