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, and a message id.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAttribute(java.lang.String attribute) Returns the given attribute value.
java.util.Map<java.lang.String,java.lang.String>	getAttributeMap() Returns the full map of attributes.
java.lang.String	getMessageId() Returns the messageId of the message populated by Cloud Pub/Sub.
byte[]	getPayload() Returns the main PubSub message.

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubMessage

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

PubsubMessage

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

Method Detail

getPayload

public byte[] getPayload()

Returns the main PubSub message.

getAttribute

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

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

getAttributeMap

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

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

getMessageId

@Nullable
public java.lang.String getMessageId()

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