Package com.azure.spring.cloud.stream.binder.eventhubs

Class EventHubsMessageChannelBinder

java.lang.Object
org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,C,P>
org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>,EventHubsChannelProvisioner>
com.azure.spring.cloud.stream.binder.eventhubs.EventHubsMessageChannelBinder
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>>, org.springframework.cloud.stream.binder.ExtendedBindingProperties<EventHubsConsumerProperties,EventHubsProducerProperties>, org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,EventHubsConsumerProperties,EventHubsProducerProperties>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware
public class EventHubsMessageChannelBinder extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>,EventHubsChannelProvisioner> implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,EventHubsConsumerProperties,EventHubsProducerProperties>

  • 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
    EventHubsMessageChannelBinder(String[] headersToEmbed, EventHubsChannelProvisioner provisioningProvider)
    Construct a EventHubsMessageChannelBinder with the specified headers to embed and EventHubsChannelProvisioner.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addProcessorFactoryCustomizer(EventHubsProcessorFactoryCustomizer processorFactoryCustomizer)
    Add a processor factory customizer.
    void
    addProducerFactoryCustomizer(EventHubsProducerFactoryCustomizer producerFactoryCustomizer)
    Add a producer factory customizer.
    protected org.springframework.integration.core.MessageProducer
    createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties> properties)
     
    protected org.springframework.messaging.MessageHandler
    createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
     
    String
    getDefaultsPrefix()
     
    EventHubsConsumerProperties
    getExtendedConsumerProperties(String destination)
     
    EventHubsProducerProperties
    getExtendedProducerProperties(String destination)
     
    Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>
    getExtendedPropertiesEntryClass()
     
    void
    setBindingProperties(EventHubsExtendedBindingProperties bindingProperties)
    Set binding properties.
    void
    setCheckpointStore(com.azure.messaging.eventhubs.CheckpointStore checkpointStore)
    Set checkpoint store.
    void
    setNamespaceProperties(com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties namespaceProperties)
    Set namespace properties.

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

    afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, createProducerMessageHandler, 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

  • Constructor Details

  • Method Details

    • createProducerMessageHandler

      protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
      Specified by:
      createProducerMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>,EventHubsChannelProvisioner>

    • createConsumerEndpoint

      protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties> properties)
      Specified by:
      createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<EventHubsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<EventHubsProducerProperties>,EventHubsChannelProvisioner>

    • getExtendedConsumerProperties

      public EventHubsConsumerProperties getExtendedConsumerProperties(String destination)
      Specified by:
      getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<EventHubsConsumerProperties,EventHubsProducerProperties>

    • getExtendedProducerProperties

      public EventHubsProducerProperties getExtendedProducerProperties(String destination)
      Specified by:
      getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<EventHubsConsumerProperties,EventHubsProducerProperties>

    • getDefaultsPrefix

      public String getDefaultsPrefix()
      Specified by:
      getDefaultsPrefix in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<EventHubsConsumerProperties,EventHubsProducerProperties>

    • getExtendedPropertiesEntryClass

      public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()
      Specified by:
      getExtendedPropertiesEntryClass in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<EventHubsConsumerProperties,EventHubsProducerProperties>

    • setBindingProperties

      public void setBindingProperties(EventHubsExtendedBindingProperties bindingProperties)
      Set binding properties.
      Parameters:
      bindingProperties - the binding properties

    • setNamespaceProperties

      public void setNamespaceProperties(com.azure.spring.messaging.eventhubs.core.properties.NamespaceProperties namespaceProperties)
      Set namespace properties.
      Parameters:
      namespaceProperties - the namespace properties

    • setCheckpointStore

      public void setCheckpointStore(com.azure.messaging.eventhubs.CheckpointStore checkpointStore)
      Set checkpoint store.
      Parameters:
      checkpointStore - the checkpoint store

    • addProducerFactoryCustomizer

      public void addProducerFactoryCustomizer(EventHubsProducerFactoryCustomizer producerFactoryCustomizer)
      Add a producer factory customizer.
      Parameters:
      producerFactoryCustomizer - The producer factory customizer to add.

    • addProcessorFactoryCustomizer

      public void addProcessorFactoryCustomizer(EventHubsProcessorFactoryCustomizer processorFactoryCustomizer)
      Add a processor factory customizer.
      Parameters:
      processorFactoryCustomizer - The processor factory customizer to add.