Package org.springframework.pulsar.autoconfigure

Class PulsarReactiveAutoConfiguration

java.lang.Object

org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration

@AutoConfiguration(after=PulsarAutoConfiguration.class)
@ConditionalOnClass({ReactivePulsarTemplate.class,org.apache.pulsar.reactive.client.api.ReactivePulsarClient.class})
@EnableConfigurationProperties(PulsarReactiveProperties.class)
@Import(PulsarReactiveAnnotationDrivenConfiguration.class)
public class PulsarReactiveAutoConfiguration
extends Object

Auto-configuration for Apache Pulsar.

Author:

Chris Bono, Christophe Bornet

Constructor Summary

Constructors

Constructor	Description
PulsarReactiveAutoConfiguration(PulsarReactiveProperties properties)

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.reactive.client.adapter.ProducerCacheProvider	pulsarProducerCacheProvider()
org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache	pulsarReactiveMessageSenderCache(ObjectProvider<org.apache.pulsar.reactive.client.adapter.ProducerCacheProvider> producerCacheProvider)
org.apache.pulsar.reactive.client.api.ReactivePulsarClient	pulsarReactivePulsarClient(org.apache.pulsar.client.api.PulsarClient pulsarClient)
ReactivePulsarTemplate<?>	pulsarReactiveTemplate(ReactivePulsarSenderFactory<?> reactivePulsarSenderFactory, SchemaResolver schemaResolver, TopicResolver topicResolver)
ReactivePulsarConsumerFactory<?>	reactivePulsarConsumerFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient)
ReactivePulsarReaderFactory<?>	reactivePulsarReaderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient)
ReactivePulsarSenderFactory<?>	reactivePulsarSenderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient, ObjectProvider<org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache> cache, TopicResolver topicResolver)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarReactiveAutoConfiguration

public PulsarReactiveAutoConfiguration(PulsarReactiveProperties properties)

Method Details

pulsarReactivePulsarClient

@Bean
@ConditionalOnMissingBean
public org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient(org.apache.pulsar.client.api.PulsarClient pulsarClient)

pulsarProducerCacheProvider

@Bean
@ConditionalOnMissingBean
@ConditionalOnClass(org.apache.pulsar.reactive.client.producercache.CaffeineProducerCacheProvider.class)
@ConditionalOnProperty(name="spring.pulsar.reactive.sender.cache.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public org.apache.pulsar.reactive.client.adapter.ProducerCacheProvider pulsarProducerCacheProvider()

pulsarReactiveMessageSenderCache

@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(name="spring.pulsar.reactive.sender.cache.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache pulsarReactiveMessageSenderCache(ObjectProvider<org.apache.pulsar.reactive.client.adapter.ProducerCacheProvider> producerCacheProvider)

reactivePulsarSenderFactory

@Bean
@ConditionalOnMissingBean
public ReactivePulsarSenderFactory<?> reactivePulsarSenderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient,
 ObjectProvider<org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache> cache,
 TopicResolver topicResolver)

reactivePulsarConsumerFactory

@Bean
@ConditionalOnMissingBean
public ReactivePulsarConsumerFactory<?> reactivePulsarConsumerFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient)

reactivePulsarReaderFactory

@Bean
@ConditionalOnMissingBean
public ReactivePulsarReaderFactory<?> reactivePulsarReaderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient)

pulsarReactiveTemplate

@Bean
@ConditionalOnMissingBean
public ReactivePulsarTemplate<?> pulsarReactiveTemplate(ReactivePulsarSenderFactory<?> reactivePulsarSenderFactory,
 SchemaResolver schemaResolver,
 TopicResolver topicResolver)