static Publisher.Builder |
Publisher.newBuilder(TopicName topicName) |
|
static Publisher.Builder |
Publisher.newBuilder(String topicName) |
|
Publisher.Builder |
Publisher.Builder.setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings) |
|
Publisher.Builder |
Publisher.Builder.setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider) |
ChannelProvider to use to create Channels, which must point at Cloud Pub/Sub
endpoint.
|
Publisher.Builder |
Publisher.Builder.setCompressionBytesThreshold(long compressionBytesThreshold) |
Sets the threshold (in bytes) above which messages are compressed for transport.
|
Publisher.Builder |
Publisher.Builder.setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider) |
CredentialsProvider to use to create Credentials to authenticate calls.
|
Publisher.Builder |
Publisher.Builder.setEnableCompression(boolean enableCompression) |
Gives the ability to enable transport compression.
|
Publisher.Builder |
Publisher.Builder.setEnableMessageOrdering(boolean enableMessageOrdering) |
Sets the message ordering option.
|
Publisher.Builder |
Publisher.Builder.setEndpoint(String endpoint) |
Gives the ability to override the gRPC endpoint.
|
Publisher.Builder |
Publisher.Builder.setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider) |
Gives the ability to set a custom executor to be used by the library.
|
Publisher.Builder |
Publisher.Builder.setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider) |
Sets the static header provider.
|
Publisher.Builder |
Publisher.Builder.setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings) |
Configures the Publisher's retry parameters.
|
Publisher.Builder |
Publisher.Builder.setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform) |
Gives the ability to set an ApiFunction that will transform the PubsubMessage
before it is sent
|