Package com.google.cloud.pubsublite.cloudpubsub (1.13.8)

GitHub Repository

Settings Classes

Settings classes can be used to configure credentials, endpoints, and retry settings for a Client.

Settings Description
com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings Describes limits on bytes and messages outstanding for a single partition Pub/Sub Lite subscriber. These are hard limits enforced by the server.
com.google.cloud.pubsublite.cloudpubsub.PublisherSettings Settings for instantiating a Pub/Sub Lite publisher emulating the Cloud Pub/Sub Publisher API.
com.google.cloud.pubsublite.cloudpubsub.SubscriberSettings Settings for instantiating a Pub/Sub Lite subscriber emulating the Cloud Pub/Sub Subscriber API.

Classes

Class Description
com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings.Builder
com.google.cloud.pubsublite.cloudpubsub.MessageTransforms MessageTransforms details how to transform message representations from Cloud Pub/Sub to Pub/Sub Lite.

Transformers are made public to allow user code that currently uses PubsubMessages to use

com.google.cloud.pubsublite.cloudpubsub.PublisherSettings.Builder
com.google.cloud.pubsublite.cloudpubsub.SubscriberSettings.Builder

Interfaces

Interface Description
com.google.cloud.pubsublite.cloudpubsub.KeyExtractor A KeyExtractor can extract the Pub/Sub Lite 'key' field used for message routing from a PubsubMessage. It will by default use the ordering_key field directly for this if it exists.

An empty ByteString implies that the message should have no ordering key.

com.google.cloud.pubsublite.cloudpubsub.NackHandler A NackHandler handles when nack() is called in a user's AckReplyConsumer. Pub/Sub Lite does not have a concept of 'nack'. When nack() is called in an AckReplyConsumerr, nack(message) is called with the nacked message.
com.google.cloud.pubsublite.cloudpubsub.PartitionSubscriberClientSupplier Supplies new SubscriberServiceClient instances.
com.google.cloud.pubsublite.cloudpubsub.Publisher Pub/Sub Lite publishers are streaming based and can experience permanent errors.
com.google.cloud.pubsublite.cloudpubsub.ReassignmentHandler A ReassignmentHandler is called any time a new partition assignment is received from the server. It will be called with both the previous and new assignments as decided by the backend.

The client library will not acknowledge the assignment until handleReassignment returns. The

com.google.cloud.pubsublite.cloudpubsub.Subscriber A sub-interface of com.google.cloud.pubsub.v1.SubscriberInterface.