com.amazonaws.services.cloudtrail.processinglibrary.serializer

Class CloudTrailValidationMessageSerializer

java.lang.Object

com.amazonaws.services.cloudtrail.processinglibrary.serializer.CloudTrailValidationMessageSerializer

All Implemented Interfaces:

SourceSerializer

public class CloudTrailValidationMessageSerializer
extends java.lang.Object
implements SourceSerializer

The CloudTrailValidationMessageSerializer extracts CloudTrail validation message from notifications that CloudTrail sends to an SNS topic. Use SourceSerializerFactory.createCloudTrailValidationMessageSerializer() for default initialization.

Constructor Summary

Constructors

Constructor and Description
CloudTrailValidationMessageSerializer(SNSMessageBodyExtractor messageExtractor)

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

CloudTrailValidationMessageSerializer

public CloudTrailValidationMessageSerializer(SNSMessageBodyExtractor messageExtractor)

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.