com.google.cloud.spring.autoconfigure.pubsub

Class GcpPubSubAutoConfiguration

java.lang.Object

com.google.cloud.spring.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, org.springframework.context.ApplicationContext applicationContext)

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(Optional<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, org.springframework.beans.factory.ObjectProvider<HealthTrackerRegistry> healthTrackerRegistry, 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)
PubSubTemplate	pubSubTemplate(PubSubPublisherTemplate pubSubPublisherTemplate, PubSubSubscriberTemplate pubSubSubscriberTemplate)
void	registerSubscriberSettings()
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,
                                  org.springframework.context.ApplicationContext applicationContext)
                           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)

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)

defaultSubscriberFactory

@Bean
 @ConditionalOnMissingBean
public SubscriberFactory defaultSubscriberFactory(@Qualifier(value="subscriberExecutorProvider")
                                                                                   Optional<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="healthTrackerRegistry")
                                                                                   org.springframework.beans.factory.ObjectProvider<HealthTrackerRegistry> healthTrackerRegistry,
                                                                                   @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()

registerSubscriberSettings

@PostConstruct
public void registerSubscriberSettings()