public class DefaultPublisherFactory extends Object implements PublisherFactory
PublisherFactory
implementation.
Creates Publisher
s for topics once, caches and reuses them.
Constructor and Description |
---|
DefaultPublisherFactory(GcpProjectIdProvider projectIdProvider)
Create
DefaultPublisherFactory instance based on the provided GcpProjectIdProvider . |
Modifier and Type | Method and Description |
---|---|
com.google.cloud.pubsub.v1.Publisher |
createPublisher(String topic) |
void |
setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)
Set the API call batching configuration.
|
void |
setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider)
Set the provider for the channel to be used by the publisher.
|
void |
setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)
Set the provider for the GCP credentials to be used by the publisher on every API calls it makes.
|
void |
setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)
Set the provider for the executor that will be used by the publisher.
|
void |
setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)
Set the provider for the HTTP headers to be used in the Pub/Sub REST API requests.
|
void |
setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings)
Set the API call retry configuration.
|
public DefaultPublisherFactory(GcpProjectIdProvider projectIdProvider)
DefaultPublisherFactory
instance based on the provided GcpProjectIdProvider
.
The GcpProjectIdProvider
must not be null, neither provide an empty projectId
.
projectIdProvider
- provides the GCP project IDpublic void setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)
public void setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider)
public void setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)
public void setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)
public void setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings)
public void setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)
public com.google.cloud.pubsub.v1.Publisher createPublisher(String topic)
createPublisher
in interface PublisherFactory
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.