public abstract static class PubsubClient.OutgoingMessage
extends java.lang.Object
implements java.io.Serializable
NOTE: This class is Serializable
only to support the PubsubTestClient
. Java
serialization is never used for non-test clients.
Constructor and Description |
---|
OutgoingMessage() |
Modifier and Type | Method and Description |
---|---|
abstract PubsubMessage |
message()
Underlying Message.
|
static PubsubClient.OutgoingMessage |
of(PubsubMessage message,
long timestampMsSinceEpoch,
@Nullable java.lang.String recordId) |
static PubsubClient.OutgoingMessage |
of(PubsubMessage message,
long timestampMsSinceEpoch,
@Nullable java.lang.String recordId) |
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 long |
timestampMsSinceEpoch()
Timestamp for element (ms since epoch).
|
public abstract PubsubMessage message()
public abstract long timestampMsSinceEpoch()
public abstract @Nullable java.lang.String recordId()
public static PubsubClient.OutgoingMessage of(PubsubMessage message, long timestampMsSinceEpoch, @Nullable java.lang.String recordId)
public static PubsubClient.OutgoingMessage of(PubsubMessage message, long timestampMsSinceEpoch, @Nullable java.lang.String recordId)