org.apache.beam.sdk.io.gcp.pubsub

Class PubsubMessage

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.PubsubMessage

public class PubsubMessage
extends java.lang.Object

Class representing a Pub/Sub message. Each message contains a single message payload, a map of attached attributes, a message id and an ordering key.

Constructor Summary

Constructors

Constructor and Description
PubsubMessage(byte[] payload, @Nullable java.util.Map<java.lang.String,java.lang.String> attributes)
PubsubMessage(byte[] payload, @Nullable java.util.Map<java.lang.String,java.lang.String> attributes, @Nullable java.lang.String messageId)
PubsubMessage(byte[] payload, @Nullable java.util.Map<java.lang.String,java.lang.String> attributes, @Nullable java.lang.String messageId, @Nullable java.lang.String orderingKey)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object other)
@Nullable java.lang.String	getAttribute(java.lang.String attribute) Returns the given attribute value.
@Nullable java.util.Map<java.lang.String,java.lang.String>	getAttributeMap() Returns the full map of attributes.
@Nullable java.lang.String	getMessageId() Returns the messageId of the message populated by Cloud Pub/Sub.
@Nullable java.lang.String	getOrderingKey() Returns the ordering key of the message.
byte[]	getPayload() Returns the main PubSub message.
@Nullable java.lang.String	getTopic()
int	hashCode()
java.lang.String	toString()
PubsubMessage	withTopic(java.lang.String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubMessage

public PubsubMessage(byte[] payload,
                     @Nullable java.util.Map<java.lang.String,java.lang.String> attributes)

PubsubMessage

public PubsubMessage(byte[] payload,
                     @Nullable java.util.Map<java.lang.String,java.lang.String> attributes,
                     @Nullable java.lang.String messageId)

PubsubMessage

public PubsubMessage(byte[] payload,
                     @Nullable java.util.Map<java.lang.String,java.lang.String> attributes,
                     @Nullable java.lang.String messageId,
                     @Nullable java.lang.String orderingKey)

Method Detail

withTopic

public PubsubMessage withTopic(java.lang.String topic)

getTopic

public @Nullable java.lang.String getTopic()

getPayload

public byte[] getPayload()

Returns the main PubSub message.

getAttribute

public @Nullable java.lang.String getAttribute(java.lang.String attribute)

Returns the given attribute value. If not such attribute exists, returns null.

getAttributeMap

public @Nullable java.util.Map<java.lang.String,java.lang.String> getAttributeMap()

Returns the full map of attributes. This is an unmodifiable map.

getMessageId

public @Nullable java.lang.String getMessageId()

Returns the messageId of the message populated by Cloud Pub/Sub.

getOrderingKey

public @Nullable java.lang.String getOrderingKey()

Returns the ordering key of the message.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object