@Configuration @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
Constructor and Description |
---|
GcpPubSubAutoConfiguration(GcpPubSubProperties gcpPubSubProperties,
GcpProjectIdProvider gcpProjectIdProvider,
com.google.api.gax.core.CredentialsProvider credentialsProvider) |
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 transportChannelProvider) |
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 transportChannelProvider) |
com.google.api.gax.batching.BatchingSettings |
publisherBatchSettings() |
com.google.api.gax.core.ExecutorProvider |
publisherExecutorProvider() |
com.google.api.gax.retrying.RetrySettings |
publisherRetrySettings() |
PubSubAdmin |
pubSubAdmin(com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient,
com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient) |
PubSubTemplate |
pubSubTemplate(PublisherFactory publisherFactory,
SubscriberFactory subscriberFactory,
org.springframework.beans.factory.ObjectProvider<PubSubMessageConverter> pubSubMessageConverter) |
com.google.api.gax.core.ExecutorProvider |
subscriberExecutorProvider() |
com.google.api.gax.batching.FlowControlSettings |
subscriberFlowControlSettings() |
com.google.api.gax.retrying.RetrySettings |
subscriberRetrySettings() |
com.google.cloud.pubsub.v1.SubscriptionAdminClient |
subscriptionAdminClient(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider) |
com.google.cloud.pubsub.v1.TopicAdminClient |
topicAdminClient(com.google.cloud.pubsub.v1.TopicAdminSettings topicAdminSettings) |
com.google.cloud.pubsub.v1.TopicAdminSettings |
topicAdminSettings(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider) |
com.google.api.gax.rpc.TransportChannelProvider |
transportChannelProvider() |
public GcpPubSubAutoConfiguration(GcpPubSubProperties gcpPubSubProperties, GcpProjectIdProvider gcpProjectIdProvider, com.google.api.gax.core.CredentialsProvider credentialsProvider) throws IOException
IOException
@Bean @ConditionalOnMissingBean(name="publisherExecutorProvider") public com.google.api.gax.core.ExecutorProvider publisherExecutorProvider()
@Bean @ConditionalOnMissingBean(name="subscriberExecutorProvider") public com.google.api.gax.core.ExecutorProvider subscriberExecutorProvider()
@Bean @ConditionalOnMissingBean public PubSubTemplate pubSubTemplate(PublisherFactory publisherFactory, SubscriberFactory subscriberFactory, org.springframework.beans.factory.ObjectProvider<PubSubMessageConverter> pubSubMessageConverter)
@Bean @ConditionalOnMissingBean(name="subscriberRetrySettings") public com.google.api.gax.retrying.RetrySettings subscriberRetrySettings()
@Bean @ConditionalOnMissingBean(name="subscriberFlowControlSettings") public com.google.api.gax.batching.FlowControlSettings subscriberFlowControlSettings()
@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, com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)
@Bean @ConditionalOnMissingBean(name="publisherBatchSettings") public com.google.api.gax.batching.BatchingSettings publisherBatchSettings()
@Bean @ConditionalOnMissingBean(name="publisherRetrySettings") public com.google.api.gax.retrying.RetrySettings publisherRetrySettings()
@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, com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)
@Bean @ConditionalOnMissingBean public PubSubAdmin pubSubAdmin(com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient, com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient)
@Bean @ConditionalOnMissingBean public com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient(com.google.cloud.pubsub.v1.TopicAdminSettings topicAdminSettings)
@Bean @ConditionalOnMissingBean public com.google.cloud.pubsub.v1.TopicAdminSettings topicAdminSettings(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)
@Bean @ConditionalOnMissingBean public com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)
@Bean @ConditionalOnMissingBean public com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider()
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.