public abstract class MessageA user message.
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 | |