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

Class PubsubClient.OutgoingMessage

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

PubsubClient

public abstract static class PubsubClient.OutgoingMessage
extends java.lang.Object
implements java.io.Serializable

A message to be sent to Pubsub.

NOTE: This class is Serializable only to support the PubsubTestClient. Java serialization is never used for non-test clients.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OutgoingMessage()

Method Summary

Modifier and Type	Method and Description
abstract com.google.pubsub.v1.PubsubMessage	getMessage() Underlying Message.
abstract long	getTimestampMsSinceEpoch() Timestamp for element (ms since epoch).
static PubsubClient.OutgoingMessage	of(com.google.pubsub.v1.PubsubMessage message, long timestampMsSinceEpoch, @Nullable java.lang.String recordId, @Nullable java.lang.String topic)
static PubsubClient.OutgoingMessage	of(PubsubMessage message, long timestampMsSinceEpoch, @Nullable java.lang.String recordId, @Nullable java.lang.String topic)
abstract @Nullable java.lang.String	recordId() If using an id attribute, the record id to associate with this record's metadata so the receiver can reject duplicates.
abstract @Nullable java.lang.String	topic()

Methods inherited from class java.lang.Object

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

Constructor Detail

OutgoingMessage

public OutgoingMessage()

Method Detail

getMessage

public abstract com.google.pubsub.v1.PubsubMessage getMessage()

Underlying Message. May not have publish timestamp set.

getTimestampMsSinceEpoch

public abstract long getTimestampMsSinceEpoch()

Timestamp for element (ms since epoch).

recordId

public abstract @Nullable java.lang.String recordId()

If using an id attribute, the record id to associate with this record's metadata so the receiver can reject duplicates. Otherwise null.

topic

public abstract @Nullable java.lang.String topic()

of

public static PubsubClient.OutgoingMessage of(com.google.pubsub.v1.PubsubMessage message,
                                              long timestampMsSinceEpoch,
                                              @Nullable java.lang.String recordId,
                                              @Nullable java.lang.String topic)

of

public static PubsubClient.OutgoingMessage of(PubsubMessage message,
                                              long timestampMsSinceEpoch,
                                              @Nullable java.lang.String recordId,
                                              @Nullable java.lang.String topic)