Package 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(org.springframework.cloud.stream.binder.Binder.class)
@ConditionalOnBean({PubSubAdmin.class,PubSubTemplate.class})
@ConditionalOnProperty(value="spring.cloud.gcp.pubsub.binder.enabled",
                       matchIfMissing=true)
@EnableConfigurationProperties(PubSubExtendedBindingProperties.class)
@ImportRuntimeHints(PubSubConsumerPropertiesRuntimeHints.class)
public class PubSubBinderConfiguration
extends Object

Pub/Sub binder configuration.

Constructor Summary

Constructors

Constructor	Description
PubSubBinderConfiguration()

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

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

Constructor Details

PubSubBinderConfiguration

public PubSubBinderConfiguration()

Method Details

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)