com.amazonaws.services.cloudtrail.processinglibrary.serializer

Class CloudTrailSourceSerializer

java.lang.Object

com.amazonaws.services.cloudtrail.processinglibrary.serializer.CloudTrailSourceSerializer

All Implemented Interfaces:

SourceSerializer

public class CloudTrailSourceSerializer
extends java.lang.Object
implements SourceSerializer

The CloudTrailSourceSerializer extracts CloudTrail log file information from notifications that CloudTrail sends to an SNS topic. Use SourceSerializerFactory.createCloudTrailSourceSerializer() for default initialization.

Constructor Summary

Constructors

Constructor and Description
CloudTrailSourceSerializer(SNSMessageBodyExtractor messageExtractor, ObjectMapper mapper, SourceIdentifier sourceIdentifier)

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

CloudTrailSourceSerializer

public CloudTrailSourceSerializer(SNSMessageBodyExtractor messageExtractor,
                                  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.