Package org.graylog.integrations.aws.transports

Class KinesisPayloadDecoder

java.lang.Object

org.graylog.integrations.aws.transports.KinesisPayloadDecoder

public class KinesisPayloadDecoder
extends Object

Responsible for decoding the raw Kinesis byte array payload.

Constructor Summary

Constructors

Constructor	Description
KinesisPayloadDecoder(com.fasterxml.jackson.databind.ObjectMapper objectMapper, AWSMessageType awsMessageType, String kinesisStream)

Method Summary

Modifier and Type	Method	Description
static CloudWatchLogSubscriptionData	decompressCloudWatchMessages(byte[] payloadBytes, com.fasterxml.jackson.databind.ObjectMapper objectMapper)	Extract CloudWatch log messages from the Kinesis payload.

Methods inherited from class java.lang.Object

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

Constructor Details

KinesisPayloadDecoder

@Inject
public KinesisPayloadDecoder(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 AWSMessageType awsMessageType,
 String kinesisStream)

Method Details

decompressCloudWatchMessages

public static CloudWatchLogSubscriptionData decompressCloudWatchMessages(byte[] payloadBytes,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)
                                                                  throws IOException

Extract CloudWatch log messages from the Kinesis payload. These messages are encoded in JSON.

Parameters:

payloadBytes - A Kinesis payload in byte array form.

objectMapper - Jackson object mapper.

Returns:

A CloudWatchLogSubscriptionData instance representing a CloudWatch subscription payload with messages.

Throws:

IOException

See Also:

• AWS Subscription Filters