Package com.google.cloud.pubsublite.internal.wire

Class SinglePartitionPublisherBuilder.Builder

java.lang.Object

com.google.cloud.pubsublite.internal.wire.SinglePartitionPublisherBuilder.Builder

Enclosing class:

SinglePartitionPublisherBuilder

public abstract static class SinglePartitionPublisherBuilder.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
Publisher<MessageMetadata>	build()
abstract SinglePartitionPublisherBuilder.Builder	setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)
abstract SinglePartitionPublisherBuilder.Builder	setClientId(com.google.protobuf.ByteString clientId)
abstract SinglePartitionPublisherBuilder.Builder	setPartition(Partition partition)
abstract SinglePartitionPublisherBuilder.Builder	setStreamFactory(StreamFactories.PublishStreamFactory streamFactory)
abstract SinglePartitionPublisherBuilder.Builder	setTopic(TopicPath topic)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

setTopic

public abstract SinglePartitionPublisherBuilder.Builder setTopic(TopicPath topic)

setPartition

public abstract SinglePartitionPublisherBuilder.Builder setPartition(Partition partition)

setStreamFactory

public abstract SinglePartitionPublisherBuilder.Builder setStreamFactory(StreamFactories.PublishStreamFactory streamFactory)

setBatchingSettings

public abstract SinglePartitionPublisherBuilder.Builder setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)

setClientId

public abstract SinglePartitionPublisherBuilder.Builder setClientId(com.google.protobuf.ByteString clientId)

build

public Publisher<MessageMetadata> build()
                                 throws com.google.api.gax.rpc.ApiException

Throws:

com.google.api.gax.rpc.ApiException