com.amazonaws.services.cloudtrail.processinglibrary.serializer

Class S3SNSSourceSerializer

java.lang.Object

com.amazonaws.services.cloudtrail.processinglibrary.serializer.S3SNSSourceSerializer

All Implemented Interfaces:

SourceSerializer

public class S3SNSSourceSerializer
extends java.lang.Object
implements SourceSerializer

The S3SnsSourceSerializer extracts CloudTrail log file information from notifications that Amazon S3 sends to an SNS topic. Use SourceSerializerFactory.createS3SNSSourceSerializer() for initialization.

Constructor Summary

Constructors

Constructor and Description
S3SNSSourceSerializer(SNSMessageBodyExtractor messageExtractor, S3SourceSerializer s3Serializer)

Method Summary

Modifier and Type	Method and Description
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

S3SNSSourceSerializer

public S3SNSSourceSerializer(SNSMessageBodyExtractor messageExtractor,
                             S3SourceSerializer s3Serializer)

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.