com.google.cloud.spring.pubsub.support

Class GcpPubSubHeaders

java.lang.Object

com.google.cloud.spring.pubsub.support.GcpPubSubHeaders

public abstract class GcpPubSubHeaders
extends Object

Google Cloud Platform internal headers for Spring Messaging messages.

Author:

João André Martins, Elena Felder, Chengyuan Zhao

Field Summary

Fields

Modifier and Type	Field and Description
static String	ORDERING_KEY The Pub/Sub message ordering key.
static String	ORIGINAL_MESSAGE The original message header text.
static String	TOPIC The topic header text.

Method Summary

Modifier and Type	Method and Description
static Optional<BasicAcknowledgeablePubsubMessage>	getOriginalMessage(org.springframework.messaging.Message<?> message) A simple utility method for pulling the ORIGINAL_MESSAGE header out of a Message.

Methods inherited from class java.lang.Object

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

Field Detail

TOPIC

public static final String TOPIC

The topic header text.

See Also:

Constant Field Values

ORIGINAL_MESSAGE

public static final String ORIGINAL_MESSAGE

The original message header text.

See Also:

Constant Field Values

ORDERING_KEY

public static final String ORDERING_KEY

The Pub/Sub message ordering key.

See Also:

Constant Field Values

Method Detail

getOriginalMessage

public static Optional<BasicAcknowledgeablePubsubMessage> getOriginalMessage(org.springframework.messaging.Message<?> message)

A simple utility method for pulling the ORIGINAL_MESSAGE header out of a Message.

Parameters:

message - The Spring Message that was converted by a PubSubInboundChannelAdapter.

Returns:

An Optional possibly containing a BasicAcknowledgeablePubsubMessage for acking and nacking.