Package org.springframework.pulsar.autoconfigure

Class PulsarAutoConfiguration

java.lang.Object

org.springframework.pulsar.autoconfigure.PulsarAutoConfiguration

@AutoConfiguration
@ConditionalOnClass(PulsarTemplate.class)
@EnableConfigurationProperties(PulsarProperties.class)
@Import(PulsarAnnotationDrivenConfiguration.class)
public class PulsarAutoConfiguration
extends Object

Auto-configuration for Apache Pulsar.

Author:

Soby Chacko, Chris Bono, Alexander Preuß

Constructor Summary

Constructors

Constructor	Description
PulsarAutoConfiguration(PulsarProperties properties)

Method Summary

Modifier and Type	Method	Description
PulsarProducerFactory<?>	cachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
PulsarAdministration	pulsarAdministration()
PulsarClientConfiguration	pulsarClientConfiguration()
PulsarClientFactoryBean	pulsarClientFactoryBean(PulsarClientConfiguration pulsarClientConfiguration)
PulsarConsumerFactory<?>	pulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
PulsarProducerFactory<?>	pulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)
PulsarTemplate<?>	pulsarTemplate(PulsarProducerFactory<?> pulsarProducerFactory, ObjectProvider<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptorsProvider, ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider, ObjectProvider<PulsarTemplateObservationConvention> observationConventionProvider)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarAutoConfiguration

public PulsarAutoConfiguration(PulsarProperties properties)

Method Details

pulsarClientConfiguration

@Bean
@ConditionalOnMissingBean(PulsarClientConfiguration.class)
public PulsarClientConfiguration pulsarClientConfiguration()

pulsarClientFactoryBean

@Bean
@ConditionalOnMissingBean(PulsarClientFactoryBean.class)
public PulsarClientFactoryBean pulsarClientFactoryBean(PulsarClientConfiguration pulsarClientConfiguration)

pulsarProducerFactory

@Bean
@ConditionalOnMissingBean(PulsarProducerFactory.class)
@ConditionalOnProperty(name="spring.pulsar.producer.cache.enabled",
                       havingValue="false")
public PulsarProducerFactory<?> pulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)

cachingPulsarProducerFactory

@Bean
@ConditionalOnMissingBean(PulsarProducerFactory.class)
@ConditionalOnProperty(name="spring.pulsar.producer.cache.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public PulsarProducerFactory<?> cachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)

pulsarTemplate

@Bean
@ConditionalOnMissingBean(PulsarTemplate.class)
public PulsarTemplate<?> pulsarTemplate(PulsarProducerFactory<?> pulsarProducerFactory,
 ObjectProvider<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptorsProvider,
 ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider,
 ObjectProvider<PulsarTemplateObservationConvention> observationConventionProvider)

pulsarConsumerFactory

@Bean
@ConditionalOnMissingBean(PulsarConsumerFactory.class)
public PulsarConsumerFactory<?> pulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient)

pulsarAdministration

@Bean
@ConditionalOnMissingBean(PulsarAdministration.class)
public PulsarAdministration pulsarAdministration()