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 PubSubMessageMessage. toProto()Convert this to a message proto.Methods in com.google.cloud.pubsublite with parameters of type PubSubMessage Modifier and Type Method Description static MessageMessage. 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.PartitionDefaultRoutingPolicy. route(PubSubMessage message)PartitionRoutingPolicy. 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 PubSubMessagePubSubMessage.Builder. build()PubSubMessagePubSubMessage.Builder. buildPartial()static PubSubMessagePubSubMessage. getDefaultInstance()PubSubMessagePubSubMessage.Builder. getDefaultInstanceForType()PubSubMessagePubSubMessage. getDefaultInstanceForType()PubSubMessageSequencedMessage.Builder. getMessage()The user message.PubSubMessageSequencedMessage. getMessage()The user message.PubSubMessageSequencedMessageOrBuilder. getMessage()The user message.PubSubMessageMessagePublishRequest.Builder. getMessages(int index)The messages to publish.PubSubMessageMessagePublishRequest. getMessages(int index)The messages to publish.PubSubMessageMessagePublishRequestOrBuilder. getMessages(int index)The messages to publish.static PubSubMessagePubSubMessage. parseDelimitedFrom(InputStream input)static PubSubMessagePubSubMessage. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessagePubSubMessage. parseFrom(byte[] data)static PubSubMessagePubSubMessage. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessagePubSubMessage. parseFrom(com.google.protobuf.ByteString data)static PubSubMessagePubSubMessage. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessagePubSubMessage. parseFrom(com.google.protobuf.CodedInputStream input)static PubSubMessagePubSubMessage. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessagePubSubMessage. parseFrom(InputStream input)static PubSubMessagePubSubMessage. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static PubSubMessagePubSubMessage. parseFrom(ByteBuffer data)static PubSubMessagePubSubMessage. 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.BuilderMessagePublishRequest.Builder. addMessages(int index, PubSubMessage value)The messages to publish.MessagePublishRequest.BuilderMessagePublishRequest.Builder. addMessages(PubSubMessage value)The messages to publish.PubSubMessage.BuilderPubSubMessage.Builder. mergeFrom(PubSubMessage other)SequencedMessage.BuilderSequencedMessage.Builder. mergeMessage(PubSubMessage value)The user message.static PubSubMessage.BuilderPubSubMessage. newBuilder(PubSubMessage prototype)SequencedMessage.BuilderSequencedMessage.Builder. setMessage(PubSubMessage value)The user message.MessagePublishRequest.BuilderMessagePublishRequest.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.BuilderMessagePublishRequest.Builder. addAllMessages(Iterable<? extends PubSubMessage> values)The messages to publish.
-