@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,
com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider) |
SubscriberFactory |
defaultSubscriberFactory(com.google.api.gax.core.ExecutorProvider executorProvider,
com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider) |
com.google.api.gax.core.ExecutorProvider |
publisherExecutorProvider() |
PubSubAdmin |
pubSubAdmin(com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient,
com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient) |
PubSubTemplate |
pubSubTemplate(PublisherFactory publisherFactory,
SubscriberFactory subscriberFactory) |
com.google.api.gax.core.ExecutorProvider |
subscriberExecutorProvider() |
com.google.cloud.pubsub.v1.SubscriptionAdminClient |
subscriptionAdminClient(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider) |
com.google.cloud.pubsub.v1.TopicAdminClient |
topicAdminClient(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)
@Bean @ConditionalOnMissingBean public SubscriberFactory defaultSubscriberFactory(@Qualifier(value="subscriberExecutorProvider") com.google.api.gax.core.ExecutorProvider executorProvider, com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)
@Bean @ConditionalOnMissingBean public PublisherFactory defaultPublisherFactory(@Qualifier(value="publisherExecutorProvider") com.google.api.gax.core.ExecutorProvider executorProvider, 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.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.