Class PulsarMessageChannelBinder
java.lang.Object
org.springframework.cloud.stream.binder.AbstractBinder<MessageChannel,C,P>
org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>,PulsarTopicProvisioner>
org.springframework.pulsar.spring.cloud.stream.binder.PulsarMessageChannelBinder
- All Implemented Interfaces:
Aware,InitializingBean,org.springframework.cloud.stream.binder.Binder<MessageChannel,,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>> org.springframework.cloud.stream.binder.ExtendedBindingProperties<PulsarConsumerProperties,,PulsarProducerProperties> org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<MessageChannel,,PulsarConsumerProperties, PulsarProducerProperties> org.springframework.cloud.stream.binder.PollableConsumerBinder<MessageHandler,,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>> ApplicationContextAware,ApplicationEventPublisherAware
public class PulsarMessageChannelBinder
extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>,PulsarTopicProvisioner>
implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<MessageChannel,PulsarConsumerProperties,PulsarProducerProperties>
Binder implementation for Apache Pulsar.- Author:
- Soby Chacko, Chris Bono
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure, org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources -
Field Summary
Fields inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
provisioningProviderFields inherited from class org.springframework.cloud.stream.binder.AbstractBinder
logger -
Constructor Summary
ConstructorsConstructorDescriptionPulsarMessageChannelBinder(PulsarTopicProvisioner provisioningProvider, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<?> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper) -
Method Summary
Modifier and TypeMethodDescriptionprotected org.springframework.integration.core.MessageProducercreateConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties> properties) protected MessageHandlercreateProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties> producerProperties, MessageChannel errorChannel) getExtendedConsumerProperties(String channelName) getExtendedProducerProperties(String channelName) Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>voidsetExtendedBindingProperties(PulsarExtendedBindingProperties extendedBindingProperties) Methods inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, createProducerMessageHandler, customizeProducerMessageHandler, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getApplicationEventPublisher, getContainerCustomizer, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandler, getErrorMessageHandlerName, getErrorMessageStrategy, getErrorRecovererName, getMessageSourceCustomizer, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, onInit, postProcessOutputChannel, postProcessPollableSource, registerErrorInfrastructure, registerErrorInfrastructure, setApplicationEventPublisher, setConsumerEndpointCustomizer, setContainerCustomizer, setProducerMessageHandlerCustomizer, useNativeEncodingMethods inherited from class org.springframework.cloud.stream.binder.AbstractBinder
afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getBindingServiceProperties, getEvaluationContext, groupedName, setApplicationContextMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.cloud.stream.binder.Binder
bindConsumer, bindProducer, getBinderIdentityMethods inherited from interface org.springframework.cloud.stream.binder.ExtendedBindingProperties
getBindings
-
Constructor Details
-
PulsarMessageChannelBinder
public PulsarMessageChannelBinder(PulsarTopicProvisioner provisioningProvider, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<?> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper)
-
-
Method Details
-
createProducerMessageHandler
protected MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties> producerProperties, MessageChannel errorChannel) - Specified by:
createProducerMessageHandlerin classorg.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>, PulsarTopicProvisioner>
-
createConsumerEndpoint
protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties> properties) - Specified by:
createConsumerEndpointin classorg.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties>, PulsarTopicProvisioner>
-
getExtendedConsumerProperties
- Specified by:
getExtendedConsumerPropertiesin interfaceorg.springframework.cloud.stream.binder.ExtendedBindingProperties<PulsarConsumerProperties,PulsarProducerProperties>
-
getExtendedProducerProperties
- Specified by:
getExtendedProducerPropertiesin interfaceorg.springframework.cloud.stream.binder.ExtendedBindingProperties<PulsarConsumerProperties,PulsarProducerProperties>
-
getDefaultsPrefix
- Specified by:
getDefaultsPrefixin interfaceorg.springframework.cloud.stream.binder.ExtendedBindingProperties<PulsarConsumerProperties,PulsarProducerProperties>
-
getExtendedPropertiesEntryClass
public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()- Specified by:
getExtendedPropertiesEntryClassin interfaceorg.springframework.cloud.stream.binder.ExtendedBindingProperties<PulsarConsumerProperties,PulsarProducerProperties>
-
getExtendedBindingProperties
-
setExtendedBindingProperties
-