org.apache.beam.sdk.io.aws2.sqs

Class SqsMessage

java.lang.Object

org.apache.beam.sdk.io.aws2.sqs.SqsMessage

All Implemented Interfaces:

java.io.Serializable

public abstract class SqsMessage
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SqsMessage()

Method Summary

Modifier and Type	Method and Description
static SqsMessage	create(java.lang.String body, java.lang.String messageId, java.lang.String receiptHandle, long timeStamp, long requestTimeStamp)
abstract java.lang.String	getBody() Message body.
abstract java.lang.String	getMessageId() SQS message id.
abstract java.lang.String	getReceiptHandle() SQS receipt handle.
abstract long	getRequestTimeStamp() Timestamp the message was received at (in epoch millis).
abstract long	getTimeStamp() Timestamp the message was sent at (in epoch millis).

Methods inherited from class java.lang.Object

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

Constructor Detail

SqsMessage

public SqsMessage()

Method Detail

getBody

public abstract java.lang.String getBody()

Message body.

getMessageId

public abstract java.lang.String getMessageId()

SQS message id.

getReceiptHandle

public abstract java.lang.String getReceiptHandle()

SQS receipt handle.

getTimeStamp

public abstract long getTimeStamp()

Timestamp the message was sent at (in epoch millis).

getRequestTimeStamp

public abstract long getRequestTimeStamp()

Timestamp the message was received at (in epoch millis).

create

public static SqsMessage create(java.lang.String body,
                                java.lang.String messageId,
                                java.lang.String receiptHandle,
                                long timeStamp,
                                long requestTimeStamp)