org.springframework.cloud.gcp.autoconfigure.pubsub

Class GcpPubSubAutoConfiguration

java.lang.Object

org.springframework.cloud.gcp.autoconfigure.pubsub.GcpPubSubAutoConfiguration

@Configuration(proxyBeanMethods=false)
 @AutoConfigureAfter(value=GcpContextAutoConfiguration.class)
 @ConditionalOnProperty(value="spring.cloud.gcp.pubsub.enabled",
                       matchIfMissing=true)
 @ConditionalOnClass(value=PubSubTemplate.class)
 @EnableConfigurationProperties(value=GcpPubSubProperties.class)
public class GcpPubSubAutoConfiguration
extends Object

Auto-config for Pub/Sub.

Author:

João André Martins, Mike Eltsufin, Chengyuan Zhao, Daniel Zou, Maurice Zeijen

Constructor Summary

Constructors

Constructor and Description
GcpPubSubAutoConfiguration(GcpPubSubProperties gcpPubSubProperties, GcpProjectIdProvider gcpProjectIdProvider, com.google.api.gax.core.CredentialsProvider credentialsProvider)

Method Summary

Modifier and Type	Method and Description
PublisherFactory	defaultPublisherFactory(com.google.api.gax.core.ExecutorProvider executorProvider, org.springframework.beans.factory.ObjectProvider<com.google.api.gax.batching.BatchingSettings> batchingSettings, org.springframework.beans.factory.ObjectProvider<com.google.api.gax.retrying.RetrySettings> retrySettings, com.google.api.gax.rpc.TransportChannelProvider publisherTransportChannelProvider)
SubscriberFactory	defaultSubscriberFactory(com.google.api.gax.core.ExecutorProvider executorProvider, org.springframework.beans.factory.ObjectProvider<com.google.api.gax.core.ExecutorProvider> systemExecutorProvider, org.springframework.beans.factory.ObjectProvider<com.google.api.gax.batching.FlowControlSettings> flowControlSettings, org.springframework.beans.factory.ObjectProvider<com.google.api.core.ApiClock> apiClock, org.springframework.beans.factory.ObjectProvider<com.google.api.gax.retrying.RetrySettings> retrySettings, com.google.api.gax.rpc.TransportChannelProvider subscriberTransportChannelProvider)
com.google.api.gax.batching.BatchingSettings	publisherBatchSettings()
com.google.api.gax.core.ExecutorProvider	publisherExecutorProvider(org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)
com.google.api.gax.retrying.RetrySettings	publisherRetrySettings()
com.google.api.gax.rpc.TransportChannelProvider	publisherTransportChannelProvider()
Executor	pubSubAcknowledgementExecutor()
PubSubAdmin	pubSubAdmin(TopicAdminClient topicAdminClient, SubscriptionAdminClient subscriptionAdminClient)
PubSubPublisherTemplate	pubSubPublisherTemplate(PublisherFactory publisherFactory, org.springframework.beans.factory.ObjectProvider<PubSubMessageConverter> pubSubMessageConverter)
org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler	pubsubPublisherThreadPool()
PubSubSubscriberTemplate	pubSubSubscriberTemplate(SubscriberFactory subscriberFactory, org.springframework.beans.factory.ObjectProvider<PubSubMessageConverter> pubSubMessageConverter, org.springframework.beans.factory.ObjectProvider<Executor> asyncPullExecutor, Executor ackExecutor)
org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler	pubsubSubscriberThreadPool()
PubSubTemplate	pubSubTemplate(PubSubPublisherTemplate pubSubPublisherTemplate, PubSubSubscriberTemplate pubSubSubscriberTemplate)
com.google.api.gax.core.ExecutorProvider	subscriberExecutorProvider(org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)
com.google.api.gax.batching.FlowControlSettings	subscriberFlowControlSettings()
com.google.api.gax.retrying.RetrySettings	subscriberRetrySettings()
com.google.api.gax.rpc.TransportChannelProvider	subscriberTransportChannelProvider()
SubscriptionAdminClient	subscriptionAdminClient(com.google.api.gax.rpc.TransportChannelProvider subscriberTransportChannelProvider)
TopicAdminClient	topicAdminClient(TopicAdminSettings topicAdminSettings)
TopicAdminSettings	topicAdminSettings(com.google.api.gax.rpc.TransportChannelProvider publisherTransportChannelProvider)

Methods inherited from class java.lang.Object

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

Constructor Detail

GcpPubSubAutoConfiguration

public GcpPubSubAutoConfiguration(GcpPubSubProperties gcpPubSubProperties,
                                  GcpProjectIdProvider gcpProjectIdProvider,
                                  com.google.api.gax.core.CredentialsProvider credentialsProvider)
                           throws IOException

Throws:

IOException

Method Detail

pubsubPublisherThreadPool

@Bean
 @ConditionalOnMissingBean(name="pubsubPublisherThreadPool")
public org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler pubsubPublisherThreadPool()

publisherExecutorProvider

@Bean
 @ConditionalOnMissingBean(name="publisherExecutorProvider")
public com.google.api.gax.core.ExecutorProvider publisherExecutorProvider(@Qualifier(value="pubsubPublisherThreadPool")
                                                                                                                                             org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)

pubsubSubscriberThreadPool

@Bean
 @ConditionalOnMissingBean(name="pubsubSubscriberThreadPool")
public org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler pubsubSubscriberThreadPool()

subscriberExecutorProvider

@Bean
 @ConditionalOnMissingBean(name="subscriberExecutorProvider")
public com.google.api.gax.core.ExecutorProvider subscriberExecutorProvider(@Qualifier(value="pubsubSubscriberThreadPool")
                                                                                                                                               org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler)

pubSubPublisherTemplate

@Bean
 @ConditionalOnMissingBean
public PubSubPublisherTemplate pubSubPublisherTemplate(PublisherFactory publisherFactory,
                                                                                        org.springframework.beans.factory.ObjectProvider<PubSubMessageConverter> pubSubMessageConverter)

pubSubAcknowledgementExecutor

@Bean
 @ConditionalOnMissingBean(name="pubSubAcknowledgementExecutor")
public Executor pubSubAcknowledgementExecutor()

pubSubSubscriberTemplate

@Bean
 @ConditionalOnMissingBean
public PubSubSubscriberTemplate pubSubSubscriberTemplate(SubscriberFactory subscriberFactory,
                                                                                          org.springframework.beans.factory.ObjectProvider<PubSubMessageConverter> pubSubMessageConverter,
                                                                                          @Qualifier(value="pubSubAsynchronousPullExecutor")
                                                                                          org.springframework.beans.factory.ObjectProvider<Executor> asyncPullExecutor,
                                                                                          @Qualifier(value="pubSubAcknowledgementExecutor")
                                                                                          Executor ackExecutor)

pubSubTemplate

@Bean
 @ConditionalOnMissingBean
public PubSubTemplate pubSubTemplate(PubSubPublisherTemplate pubSubPublisherTemplate,
                                                                      PubSubSubscriberTemplate pubSubSubscriberTemplate)

subscriberRetrySettings

@Bean
 @ConditionalOnMissingBean(name="subscriberRetrySettings")
public com.google.api.gax.retrying.RetrySettings subscriberRetrySettings()

subscriberFlowControlSettings

@Bean
 @ConditionalOnMissingBean(name="subscriberFlowControlSettings")
public com.google.api.gax.batching.FlowControlSettings subscriberFlowControlSettings()

defaultSubscriberFactory

@Bean
 @ConditionalOnMissingBean
public SubscriberFactory defaultSubscriberFactory(@Qualifier(value="subscriberExecutorProvider")
                                                                                   com.google.api.gax.core.ExecutorProvider executorProvider,
                                                                                   @Qualifier(value="subscriberSystemExecutorProvider")
                                                                                   org.springframework.beans.factory.ObjectProvider<com.google.api.gax.core.ExecutorProvider> systemExecutorProvider,
                                                                                   @Qualifier(value="subscriberFlowControlSettings")
                                                                                   org.springframework.beans.factory.ObjectProvider<com.google.api.gax.batching.FlowControlSettings> flowControlSettings,
                                                                                   @Qualifier(value="subscriberApiClock")
                                                                                   org.springframework.beans.factory.ObjectProvider<com.google.api.core.ApiClock> apiClock,
                                                                                   @Qualifier(value="subscriberRetrySettings")
                                                                                   org.springframework.beans.factory.ObjectProvider<com.google.api.gax.retrying.RetrySettings> retrySettings,
                                                                                   @Qualifier(value="subscriberTransportChannelProvider")
                                                                                   com.google.api.gax.rpc.TransportChannelProvider subscriberTransportChannelProvider)

publisherBatchSettings

@Bean
 @ConditionalOnMissingBean(name="publisherBatchSettings")
public com.google.api.gax.batching.BatchingSettings publisherBatchSettings()

publisherRetrySettings

@Bean
 @ConditionalOnMissingBean(name="publisherRetrySettings")
public com.google.api.gax.retrying.RetrySettings publisherRetrySettings()

defaultPublisherFactory

@Bean
 @ConditionalOnMissingBean
public PublisherFactory defaultPublisherFactory(@Qualifier(value="publisherExecutorProvider")
                                                                                 com.google.api.gax.core.ExecutorProvider executorProvider,
                                                                                 @Qualifier(value="publisherBatchSettings")
                                                                                 org.springframework.beans.factory.ObjectProvider<com.google.api.gax.batching.BatchingSettings> batchingSettings,
                                                                                 @Qualifier(value="publisherRetrySettings")
                                                                                 org.springframework.beans.factory.ObjectProvider<com.google.api.gax.retrying.RetrySettings> retrySettings,
                                                                                 @Qualifier(value="publisherTransportChannelProvider")
                                                                                 com.google.api.gax.rpc.TransportChannelProvider publisherTransportChannelProvider)

pubSubAdmin

@Bean
 @ConditionalOnMissingBean
public PubSubAdmin pubSubAdmin(TopicAdminClient topicAdminClient,
                                                                SubscriptionAdminClient subscriptionAdminClient)

topicAdminClient

@Bean
 @ConditionalOnMissingBean
public TopicAdminClient topicAdminClient(TopicAdminSettings topicAdminSettings)

topicAdminSettings

@Bean
 @ConditionalOnMissingBean
public TopicAdminSettings topicAdminSettings(@Qualifier(value="publisherTransportChannelProvider")
                                                                              com.google.api.gax.rpc.TransportChannelProvider publisherTransportChannelProvider)

subscriptionAdminClient

@Bean
 @ConditionalOnMissingBean
public SubscriptionAdminClient subscriptionAdminClient(@Qualifier(value="subscriberTransportChannelProvider")
                                                                                        com.google.api.gax.rpc.TransportChannelProvider subscriberTransportChannelProvider)

subscriberTransportChannelProvider

@Bean
 @ConditionalOnMissingBean(name="subscriberTransportChannelProvider")
public com.google.api.gax.rpc.TransportChannelProvider subscriberTransportChannelProvider()

publisherTransportChannelProvider

@Bean
 @ConditionalOnMissingBean(name="publisherTransportChannelProvider")
public com.google.api.gax.rpc.TransportChannelProvider publisherTransportChannelProvider()