com.google.cloud.spring.stream.binder.pubsub.config

Class PubSubBinderConfiguration

java.lang.Object

com.google.cloud.spring.stream.binder.pubsub.config.PubSubBinderConfiguration

@Configuration(proxyBeanMethods=false)
 @ConditionalOnMissingBean(value=org.springframework.cloud.stream.binder.Binder.class)
 @ConditionalOnBean(value={PubSubAdmin.class,PubSubTemplate.class})
 @ConditionalOnProperty(value="spring.cloud.gcp.pubsub.binder.enabled",
                       matchIfMissing=true)
 @EnableConfigurationProperties(value=PubSubExtendedBindingProperties.class)
public class PubSubBinderConfiguration
extends Object

Pub/Sub binder configuration.

Author:

João André Martins, Daniel Zou, Mike Eltsufin

Constructor Summary

Constructors

Constructor and Description
PubSubBinderConfiguration()

Method Summary

Modifier and Type	Method and Description
PubSubMessageChannelBinder	pubSubBinder(PubSubChannelProvisioner pubSubChannelProvisioner, PubSubTemplate pubSubTemplate, PubSubExtendedBindingProperties pubSubExtendedBindingProperties, org.springframework.cloud.stream.config.ProducerMessageHandlerCustomizer<PubSubMessageHandler> producerCustomizer, org.springframework.cloud.stream.config.ConsumerEndpointCustomizer<PubSubInboundChannelAdapter> consumerCustomizer, HealthTrackerRegistry healthTrackerRegistry)
PubSubChannelProvisioner	pubSubChannelProvisioner(PubSubAdmin pubSubAdmin)
org.springframework.cloud.stream.config.BindingHandlerAdvise.MappingsProvider	pubSubExtendedPropertiesDefaultMappingsProvider()

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubBinderConfiguration

public PubSubBinderConfiguration()

Method Detail

pubSubChannelProvisioner

@Bean
public PubSubChannelProvisioner pubSubChannelProvisioner(PubSubAdmin pubSubAdmin)

pubSubBinder

@Bean
public PubSubMessageChannelBinder pubSubBinder(PubSubChannelProvisioner pubSubChannelProvisioner,
                                                     PubSubTemplate pubSubTemplate,
                                                     PubSubExtendedBindingProperties pubSubExtendedBindingProperties,
                                                     @Nullable
                                                     org.springframework.cloud.stream.config.ProducerMessageHandlerCustomizer<PubSubMessageHandler> producerCustomizer,
                                                     @Nullable
                                                     org.springframework.cloud.stream.config.ConsumerEndpointCustomizer<PubSubInboundChannelAdapter> consumerCustomizer,
                                                     @Nullable
                                                     HealthTrackerRegistry healthTrackerRegistry)

pubSubExtendedPropertiesDefaultMappingsProvider

@Bean
public org.springframework.cloud.stream.config.BindingHandlerAdvise.MappingsProvider pubSubExtendedPropertiesDefaultMappingsProvider()