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

Class SqsMessage

java.lang.Object

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

All Implemented Interfaces:

Serializable

public abstract class SqsMessage
extends Object
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SqsMessage()

Method Summary

Modifier and Type	Method	Description
static SqsMessage	create(String body, String messageId, String receiptHandle, long timeStamp, long requestTimeStamp)
abstract String	getBody()	Message body.
abstract String	getMessageId()	SQS message id.
abstract 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 Details

SqsMessage

public SqsMessage()

Method Details

getBody

public abstract String getBody()

Message body.

getMessageId

public abstract String getMessageId()

SQS message id.

getReceiptHandle

public abstract 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(String body,
 String messageId,
 String receiptHandle,
 long timeStamp,
 long requestTimeStamp)