io.awspring.cloud.messaging.core

Class SqsMessageHeaders

java.lang.Object

org.springframework.messaging.MessageHeaders

io.awspring.cloud.messaging.core.SqsMessageHeaders

All Implemented Interfaces:

Serializable, Map<String,Object>

public class SqsMessageHeaders
extends MessageHeaders

Specialization of the MessageHeaders class that allows to set an ID. This was done to support cases where the ID sent by the producer must be restored on the consumer side for traceability.

Since:

1.0

Author:

Alain Sahli, Wojciech Mąka

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
static String	SQS_APPROXIMATE_FIRST_RECEIVE_TIMESTAMP ApproximateFirstReceiveTimestamp header in a SQS message.
static String	SQS_APPROXIMATE_RECEIVE_COUNT ApproximateReceiveCount header in a SQS message.
static String	SQS_DEDUPLICATION_ID_HEADER Deduplication header in a SQS message.
static String	SQS_DELAY_HEADER Delay header in a SQS message.
static String	SQS_GROUP_ID_HEADER Group id header in a SQS message.
static String	SQS_SENT_TIMESTAMP SentTimestamp header in a SQS message.

Fields inherited from class org.springframework.messaging.MessageHeaders

CONTENT_TYPE, ERROR_CHANNEL, ID, ID_VALUE_NONE, REPLY_CHANNEL, TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
SqsMessageHeaders(Map<String,Object> headers)

Method Summary

Modifier and Type	Method and Description
Long	getApproximateFirstReceiveTimestamp()
Long	getApproximateReceiveCount()
Long	getSentTimestamp()

Methods inherited from class org.springframework.messaging.MessageHeaders

clear, containsKey, containsValue, entrySet, equals, get, get, getErrorChannel, getId, getIdGenerator, getRawHeaders, getReplyChannel, getTimestamp, hashCode, isEmpty, keySet, put, putAll, remove, size, toString, values

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Field Detail

SQS_DELAY_HEADER

public static final String SQS_DELAY_HEADER

Delay header in a SQS message.

See Also:

Constant Field Values

SQS_GROUP_ID_HEADER

public static final String SQS_GROUP_ID_HEADER

Group id header in a SQS message.

See Also:

Constant Field Values

SQS_DEDUPLICATION_ID_HEADER

public static final String SQS_DEDUPLICATION_ID_HEADER

Deduplication header in a SQS message.

See Also:

Constant Field Values

SQS_APPROXIMATE_FIRST_RECEIVE_TIMESTAMP

public static final String SQS_APPROXIMATE_FIRST_RECEIVE_TIMESTAMP

ApproximateFirstReceiveTimestamp header in a SQS message.

See Also:

Constant Field Values

SQS_APPROXIMATE_RECEIVE_COUNT

public static final String SQS_APPROXIMATE_RECEIVE_COUNT

ApproximateReceiveCount header in a SQS message.

See Also:

Constant Field Values

SQS_SENT_TIMESTAMP

public static final String SQS_SENT_TIMESTAMP

SentTimestamp header in a SQS message.

See Also:

Constant Field Values

Constructor Detail

SqsMessageHeaders

public SqsMessageHeaders(Map<String,Object> headers)

Method Detail

getApproximateFirstReceiveTimestamp

public Long getApproximateFirstReceiveTimestamp()

getSentTimestamp

public Long getSentTimestamp()

getApproximateReceiveCount

public Long getApproximateReceiveCount()