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 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

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Map<java.lang.String,java.lang.String>	attributes
byte[]	elementBytes Underlying (encoded) element.
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.
long	timestampMsSinceEpoch Timestamp for element (ms since epoch).

Constructor Summary

Constructors

Constructor and Description
OutgoingMessage(byte[] elementBytes, java.util.Map<java.lang.String,java.lang.String> attributes, long timestampMsSinceEpoch, java.lang.String recordId)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

elementBytes

public final byte[] elementBytes

Underlying (encoded) element.

attributes

public final java.util.Map<java.lang.String,java.lang.String> attributes

timestampMsSinceEpoch

public final long timestampMsSinceEpoch

Timestamp for element (ms since epoch).

recordId

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

Constructor Detail

OutgoingMessage

public OutgoingMessage(byte[] elementBytes,
                       java.util.Map<java.lang.String,java.lang.String> attributes,
                       long timestampMsSinceEpoch,
                       @Nullable
                       java.lang.String recordId)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object