Uses of Class
com.google.cloud.pubsublite.proto.PubSubMessage
-
Packages that use PubSubMessage Package Description com.google.cloud.pubsublite com.google.cloud.pubsublite.internal com.google.cloud.pubsublite.internal.wire com.google.cloud.pubsublite.proto -
-
Uses of PubSubMessage in com.google.cloud.pubsublite
Methods in com.google.cloud.pubsublite that return PubSubMessage Modifier and Type Method Description PubSubMessage
Message. toProto()
Convert this to a message proto.Methods in com.google.cloud.pubsublite with parameters of type PubSubMessage Modifier and Type Method Description static Message
Message. fromProto(PubSubMessage proto)
Construct a message from a proto. -
Uses of PubSubMessage in com.google.cloud.pubsublite.internal
Methods in com.google.cloud.pubsublite.internal with parameters of type PubSubMessage Modifier and Type Method Description com.google.api.core.ApiFuture<ResponseT>
Publisher. publish(PubSubMessage message)
com.google.api.core.ApiFuture<ResponseT>
SequencedPublisher. publish(PubSubMessage message, PublishSequenceNumber sequenceNumber)
Publish a new message with an assigned sequence number.Partition
DefaultRoutingPolicy. route(PubSubMessage message)
Partition
RoutingPolicy. route(PubSubMessage messageKey)
-
Uses of PubSubMessage in com.google.cloud.pubsublite.internal.wire
Methods in com.google.cloud.pubsublite.internal.wire with parameters of type PubSubMessage Modifier and Type Method Description com.google.api.core.ApiFuture<T>
ApiExceptionPublisher. publish(PubSubMessage message)
com.google.api.core.ApiFuture<MessageMetadata>
PartitionCountWatchingPublisher. publish(PubSubMessage message)
com.google.api.core.ApiFuture<Offset>
PublisherImpl. publish(PubSubMessage message, PublishSequenceNumber sequenceNumber)
com.google.api.core.ApiFuture<MessageMetadata>
RoutingPublisher. publish(PubSubMessage message)
com.google.api.core.ApiFuture<Offset>
SequenceAssigningPublisher. publish(PubSubMessage message)
com.google.api.core.ApiFuture<MessageMetadata>
SinglePartitionPublisher. publish(PubSubMessage message)
-
Uses of PubSubMessage in com.google.cloud.pubsublite.proto
Methods in com.google.cloud.pubsublite.proto that return PubSubMessage Modifier and Type Method Description PubSubMessage
PubSubMessage.Builder. build()
PubSubMessage
PubSubMessage.Builder. buildPartial()
static PubSubMessage
PubSubMessage. getDefaultInstance()
PubSubMessage
PubSubMessage.Builder. getDefaultInstanceForType()
PubSubMessage
PubSubMessage. getDefaultInstanceForType()
PubSubMessage
SequencedMessage.Builder. getMessage()
The user message.PubSubMessage
SequencedMessage. getMessage()
The user message.PubSubMessage
SequencedMessageOrBuilder. getMessage()
The user message.PubSubMessage
MessagePublishRequest.Builder. getMessages(int index)
The messages to publish.PubSubMessage
MessagePublishRequest. getMessages(int index)
The messages to publish.PubSubMessage
MessagePublishRequestOrBuilder. getMessages(int index)
The messages to publish.static PubSubMessage
PubSubMessage. parseDelimitedFrom(InputStream input)
static PubSubMessage
PubSubMessage. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubMessage
PubSubMessage. parseFrom(byte[] data)
static PubSubMessage
PubSubMessage. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubMessage
PubSubMessage. parseFrom(com.google.protobuf.ByteString data)
static PubSubMessage
PubSubMessage. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubMessage
PubSubMessage. parseFrom(com.google.protobuf.CodedInputStream input)
static PubSubMessage
PubSubMessage. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubMessage
PubSubMessage. parseFrom(InputStream input)
static PubSubMessage
PubSubMessage. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static PubSubMessage
PubSubMessage. parseFrom(ByteBuffer data)
static PubSubMessage
PubSubMessage. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Methods in com.google.cloud.pubsublite.proto that return types with arguments of type PubSubMessage Modifier and Type Method Description List<PubSubMessage>
MessagePublishRequest.Builder. getMessagesList()
The messages to publish.List<PubSubMessage>
MessagePublishRequest. getMessagesList()
The messages to publish.List<PubSubMessage>
MessagePublishRequestOrBuilder. getMessagesList()
The messages to publish.com.google.protobuf.Parser<PubSubMessage>
PubSubMessage. getParserForType()
static com.google.protobuf.Parser<PubSubMessage>
PubSubMessage. parser()
Methods in com.google.cloud.pubsublite.proto with parameters of type PubSubMessage Modifier and Type Method Description MessagePublishRequest.Builder
MessagePublishRequest.Builder. addMessages(int index, PubSubMessage value)
The messages to publish.MessagePublishRequest.Builder
MessagePublishRequest.Builder. addMessages(PubSubMessage value)
The messages to publish.PubSubMessage.Builder
PubSubMessage.Builder. mergeFrom(PubSubMessage other)
SequencedMessage.Builder
SequencedMessage.Builder. mergeMessage(PubSubMessage value)
The user message.static PubSubMessage.Builder
PubSubMessage. newBuilder(PubSubMessage prototype)
SequencedMessage.Builder
SequencedMessage.Builder. setMessage(PubSubMessage value)
The user message.MessagePublishRequest.Builder
MessagePublishRequest.Builder. setMessages(int index, PubSubMessage value)
The messages to publish.Method parameters in com.google.cloud.pubsublite.proto with type arguments of type PubSubMessage Modifier and Type Method Description MessagePublishRequest.Builder
MessagePublishRequest.Builder. addAllMessages(Iterable<? extends PubSubMessage> values)
The messages to publish.
-