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 PubsubMessage	message() Underlying Message.
static PubsubClient.OutgoingMessage	of(PubsubMessage message, long timestampMsSinceEpoch, java.lang.String recordId)
static PubsubClient.OutgoingMessage	of(PubsubMessage message, long timestampMsSinceEpoch, java.lang.String recordId)
abstract 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 long	timestampMsSinceEpoch() Timestamp for element (ms since epoch).

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

message

public abstract PubsubMessage message()

Underlying Message. May not have publish timestamp set.

timestampMsSinceEpoch

public abstract long timestampMsSinceEpoch()

Timestamp for element (ms since epoch).

recordId

@Nullable
public abstract 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.

of

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

of

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