Modifier and Type | Method and Description |
---|---|
Publisher |
build() |
static com.google.api.gax.batching.BatchingSettings |
getDefaultBatchingSettings()
Returns the default BatchingSettings used by the client if settings are not provided.
|
Publisher.Builder |
setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings) |
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 |
setCompressionBytesThreshold(long compressionBytesThreshold)
Sets the threshold (in bytes) above which messages are compressed for transport.
|
Publisher.Builder |
setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)
CredentialsProvider to use to create Credentials to authenticate calls. |
Publisher.Builder |
setEnableCompression(boolean enableCompression)
Gives the ability to enable transport compression.
|
Publisher.Builder |
setEnableMessageOrdering(boolean enableMessageOrdering)
Sets the message ordering option.
|
Publisher.Builder |
setEndpoint(String endpoint)
Gives the ability to override the gRPC endpoint.
|
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 |
setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)
Sets the static header provider.
|
Publisher.Builder |
setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings)
Configures the Publisher's retry parameters.
|
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 |
public Publisher.Builder setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider)
ChannelProvider
to use to create Channels, which must point at Cloud Pub/Sub
endpoint.
For performance, this client benefits from having multiple underlying connections. See
InstantiatingGrpcChannelProvider.Builder.setPoolSize(int)
.
@BetaApi public Publisher.Builder setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)
headerProvider
- the header providerpublic Publisher.Builder setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)
CredentialsProvider
to use to create Credentials to authenticate calls.public Publisher.Builder setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)
public Publisher.Builder setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings)
public Publisher.Builder setEnableMessageOrdering(boolean enableMessageOrdering)
public Publisher.Builder setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)
@BetaApi public Publisher.Builder setTransform(com.google.api.core.ApiFunction<PubsubMessage,PubsubMessage> messageTransform)
ApiFunction
that will transform the PubsubMessage
before it is sentpublic Publisher.Builder setEndpoint(String endpoint)
public Publisher.Builder setEnableCompression(boolean enableCompression)
public Publisher.Builder setCompressionBytesThreshold(long compressionBytesThreshold)
public static com.google.api.gax.batching.BatchingSettings getDefaultBatchingSettings()
public Publisher build() throws IOException
IOException
Copyright © 2023 Google LLC. All rights reserved.