Package 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 internal headers for Spring Messaging messages.

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	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 Details

CLIENT

public static final String CLIENT

The client header text.

See Also:

• Constant Field Values

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 Details

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.