Package com.google.cloud.pubsublite.cloudpubsub

Class PublisherSettings.Builder

java.lang.Object

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

Enclosing class:

PublisherSettings

public abstract static class PublisherSettings.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract PublisherSettings	build()
abstract PublisherSettings.Builder	setAdminClient(AdminClient adminClient)	The AdminClient to use, if provided.
abstract PublisherSettings.Builder	setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)	Batching settings for this publisher to use.
abstract PublisherSettings.Builder	setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)	A provider for credentials.
abstract PublisherSettings.Builder	setEnableCompression(boolean enableCompression)	Whether request compression is enabled.
abstract PublisherSettings.Builder	setEnableIdempotence(boolean enableIdempotence)	Whether idempotence is enabled, where the server will ensure that unique messages within a single publisher session are stored only once.
abstract PublisherSettings.Builder	setFramework(PubsubContext.Framework framework)	A Framework tag for internal metrics.
abstract PublisherSettings.Builder	setKeyExtractor(KeyExtractor keyExtractor)	A KeyExtractor for getting the routing key from a message.
abstract PublisherSettings.Builder	setMessageTransformer(MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> messageTransformer)	A MessageTransformer for constructing wire messages from Cloud Pub/Sub PubsubMessages.
abstract PublisherSettings.Builder	setServiceClient(PublisherServiceClient client)	The PublisherServiceClient to use, if provided.
abstract PublisherSettings.Builder	setTopicPath(TopicPath path)	The topic path to publish to.

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

setTopicPath

public abstract PublisherSettings.Builder setTopicPath(TopicPath path)

The topic path to publish to.

setKeyExtractor

public abstract PublisherSettings.Builder setKeyExtractor(KeyExtractor keyExtractor)

A KeyExtractor for getting the routing key from a message.

setMessageTransformer

public abstract PublisherSettings.Builder setMessageTransformer(MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> messageTransformer)

A MessageTransformer for constructing wire messages from Cloud Pub/Sub PubsubMessages.

setBatchingSettings

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

Batching settings for this publisher to use. Apply per-partition.

setEnableIdempotence

public abstract PublisherSettings.Builder setEnableIdempotence(boolean enableIdempotence)

Whether idempotence is enabled, where the server will ensure that unique messages within a single publisher session are stored only once. Default true.

setEnableCompression

public abstract PublisherSettings.Builder setEnableCompression(boolean enableCompression)

Whether request compression is enabled. Default true.

setCredentialsProvider

public abstract PublisherSettings.Builder setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)

A provider for credentials.

setFramework

public abstract PublisherSettings.Builder setFramework(PubsubContext.Framework framework)

A Framework tag for internal metrics. Please set this if integrating with a public framework!

setServiceClient

public abstract PublisherSettings.Builder setServiceClient(PublisherServiceClient client)

The PublisherServiceClient to use, if provided.

setAdminClient

public abstract PublisherSettings.Builder setAdminClient(AdminClient adminClient)

The AdminClient to use, if provided.

build

public abstract PublisherSettings build()