Class PulsarBinderConfiguration
java.lang.Object
org.springframework.pulsar.spring.cloud.stream.binder.config.PulsarBinderConfiguration
@Configuration(proxyBeanMethods=false)
@ConditionalOnMissingBean(org.springframework.cloud.stream.binder.Binder.class)
@EnableConfigurationProperties({PulsarProperties.class,PulsarExtendedBindingProperties.class,PulsarBinderConfigurationProperties.class})
public class PulsarBinderConfiguration
extends Object
Pulsar binder
Configuration.- Author:
- Soby Chacko
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionpulsarMessageChannelBinder(PulsarTopicProvisioner pulsarTopicProvisioner, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<byte[]> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, PulsarExtendedBindingProperties bindingConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper) pulsarTopicProvisioner(PulsarAdministration pulsarAdministration, PulsarBinderConfigurationProperties pulsarBinderConfigurationProperties)
-
Constructor Details
-
PulsarBinderConfiguration
public PulsarBinderConfiguration()
-
-
Method Details
-
pulsarTopicProvisioner
@Bean public PulsarTopicProvisioner pulsarTopicProvisioner(PulsarAdministration pulsarAdministration, PulsarBinderConfigurationProperties pulsarBinderConfigurationProperties) -
pulsarHeaderMapper
-
pulsarMessageChannelBinder
@Bean public PulsarMessageChannelBinder pulsarMessageChannelBinder(PulsarTopicProvisioner pulsarTopicProvisioner, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<byte[]> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, PulsarExtendedBindingProperties bindingConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper)
-