Package com.google.cloud.spring.autoconfigure.pubsub

Class GcpPubSubReactiveAutoConfiguration

java.lang.Object

com.google.cloud.spring.autoconfigure.pubsub.GcpPubSubReactiveAutoConfiguration

@AutoConfiguration
@AutoConfigureAfter(GcpPubSubAutoConfiguration.class)
@ConditionalOnClass({reactor.core.publisher.Flux.class,PubSubSubscriberTemplate.class})
@ConditionalOnProperty(value={"spring.cloud.gcp.pubsub.reactive.enabled","spring.cloud.gcp.pubsub.enabled"},
                       matchIfMissing=true)
public class GcpPubSubReactiveAutoConfiguration
extends Object

Reactive Pub/Sub support autoconfiguration.

Since:

1.2

Constructor Summary

Constructors

Constructor	Description
GcpPubSubReactiveAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
PubSubReactiveFactory	pubSubReactiveFactory(PubSubSubscriberTemplate subscriberTemplate, Optional<reactor.core.scheduler.Scheduler> userProvidedScheduler)

Methods inherited from class java.lang.Object

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

Constructor Details

GcpPubSubReactiveAutoConfiguration

public GcpPubSubReactiveAutoConfiguration()

Method Details

pubSubReactiveFactory

@Bean
@ConditionalOnMissingBean
public PubSubReactiveFactory pubSubReactiveFactory(PubSubSubscriberTemplate subscriberTemplate,
 @Qualifier("pubSubReactiveScheduler")
 Optional<reactor.core.scheduler.Scheduler> userProvidedScheduler)