Package org.springframework.pulsar.spring.cloud.stream.binder

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

    provisioningProvider

    Fields inherited from class org.springframework.cloud.stream.binder.AbstractBinder

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    PulsarMessageChannelBinder(PulsarTopicProvisioner provisioningProvider, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<?> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.springframework.integration.core.MessageProducer
    createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PulsarConsumerProperties> properties)
     
    protected MessageHandler
    createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PulsarProducerProperties> producerProperties, MessageChannel errorChannel)
     
    String
    getDefaultsPrefix()
     
    PulsarExtendedBindingProperties
    getExtendedBindingProperties()
     
    PulsarConsumerProperties
    getExtendedConsumerProperties(String channelName)
     
    PulsarProducerProperties
    getExtendedProducerProperties(String channelName)
     
    Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>
    getExtendedPropertiesEntryClass()
     
    void
    setExtendedBindingProperties(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, useNativeEncoding

    Methods inherited from class org.springframework.cloud.stream.binder.AbstractBinder

    afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getBindingServiceProperties, getEvaluationContext, groupedName, setApplicationContext

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.cloud.stream.binder.Binder

    bindConsumer, bindProducer, getBinderIdentity

    Methods inherited from interface org.springframework.cloud.stream.binder.ExtendedBindingProperties

    getBindings