Uses of Class
com.google.cloud.pubsublite.MessageMetadata
-
Packages that use MessageMetadata Package Description com.google.cloud.pubsublite com.google.cloud.pubsublite.cloudpubsub.internal com.google.cloud.pubsublite.internal.wire -
-
Uses of MessageMetadata in com.google.cloud.pubsublite
Methods in com.google.cloud.pubsublite that return MessageMetadata Modifier and Type Method Description static MessageMetadataMessageMetadata. decode(String encoded)Decode a MessageMetadata from the Cloud Pub/Sub ack id.static MessageMetadataMessageMetadata. of(Partition partition, Offset offset)Construct a MessageMetadata from a Partition and Offset. -
Uses of MessageMetadata in com.google.cloud.pubsublite.cloudpubsub.internal
Constructor parameters in com.google.cloud.pubsublite.cloudpubsub.internal with type arguments of type MessageMetadata Constructor Description WrappingPublisher(Publisher<MessageMetadata> wirePublisher, MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> transformer) -
Uses of MessageMetadata in com.google.cloud.pubsublite.internal.wire
Methods in com.google.cloud.pubsublite.internal.wire that return types with arguments of type MessageMetadata Modifier and Type Method Description Publisher<MessageMetadata>RoutingPublisherBuilder.Builder. build()Publisher<MessageMetadata>SinglePartitionPublisherBuilder.Builder. build()Publisher<MessageMetadata>PartitionCountWatchingPublisherSettings. instantiate()Publisher<MessageMetadata>PartitionPublisherFactory. newPublisher(Partition partition)com.google.api.core.ApiFuture<MessageMetadata>PartitionCountWatchingPublisher. publish(PubSubMessage message)com.google.api.core.ApiFuture<MessageMetadata>RoutingPublisher. publish(PubSubMessage message)com.google.api.core.ApiFuture<MessageMetadata>SinglePartitionPublisher. publish(PubSubMessage message)
-