Uses of Interface
com.google.cloud.pubsublite.internal.Publisher
-
Packages that use Publisher Package Description com.google.cloud.pubsublite.cloudpubsub.internal com.google.cloud.pubsublite.internal.wire -
-
Uses of Publisher in com.google.cloud.pubsublite.cloudpubsub.internal
Constructors in com.google.cloud.pubsublite.cloudpubsub.internal with parameters of type Publisher Constructor Description WrappingPublisher(Publisher<MessageMetadata> wirePublisher, MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> transformer)
-
Uses of Publisher in com.google.cloud.pubsublite.internal.wire
Classes in com.google.cloud.pubsublite.internal.wire that implement Publisher Modifier and Type Class Description class
ApiExceptionPublisher<T>
class
PartitionCountWatchingPublisher
class
RoutingPublisher
class
SequenceAssigningPublisher
A publisher that assigns sequence numbers to messages and delegates to an underlying SequencedPublisher.class
SinglePartitionPublisher
Methods in com.google.cloud.pubsublite.internal.wire that return Publisher Modifier and Type Method Description Publisher<Offset>
PublisherBuilder.Builder. build()
Publisher<MessageMetadata>
RoutingPublisherBuilder.Builder. build()
Publisher<MessageMetadata>
SinglePartitionPublisherBuilder.Builder. build()
Publisher<MessageMetadata>
PartitionCountWatchingPublisherSettings. instantiate()
Publisher<MessageMetadata>
PartitionPublisherFactory. newPublisher(Partition partition)
-