Class Message (1.10.0)

public abstract class Message

A user message.

Inheritance

java.lang.Object > Message

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Methods

builder()

public static Message.Builder builder()

Get a new builder for a message.

Returns

Type	Description
`Message.Builder`

fromProto(PubSubMessage proto)

public static Message fromProto(PubSubMessage proto)

Construct a message from a proto.

Parameter

Name	Description
`proto`	`PubSubMessage`

Returns

Type	Description
`Message`

Constructors

Message()

public Message()

Methods

attributes()

public abstract ImmutableListMultimap<String,ByteString> attributes()

A multimap of attributes for this message.

Returns

Type	Description
`com.google.common.collect.ImmutableListMultimap<String,ByteString>`

data()

public abstract ByteString data()

The data payload for this message.

Returns

Type	Description
`ByteString`

eventTime()

public abstract Optional<Timestamp> eventTime()

The user-provided event time for this message.

Returns

Type	Description
`Optional<Timestamp>`

key()

public abstract ByteString key()

The key for this message. All messages with the same key are routed to the same partition.

Returns

Type	Description
`ByteString`

toBuilder()

public abstract Message.Builder toBuilder()

Convert an existing message to a builder.

Returns

Type	Description
`Message.Builder`

toProto()

public PubSubMessage toProto()

Convert this to a message proto.

Returns

Type	Description
`PubSubMessage`