com.azure.spring.servicebus.stream.binder

Class ServiceBusQueueMessageChannelBinder

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<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>,ServiceBusChannelProvisioner>

com.azure.spring.servicebus.stream.binder.ServiceBusMessageChannelBinder<ServiceBusQueueExtendedBindingProperties>

com.azure.spring.servicebus.stream.binder.ServiceBusQueueMessageChannelBinder

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<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>>, org.springframework.cloud.stream.binder.ExtendedBindingProperties<C,P>, org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,ServiceBusConsumerProperties,ServiceBusProducerProperties>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware

public class ServiceBusQueueMessageChannelBinder
extends ServiceBusMessageChannelBinder<ServiceBusQueueExtendedBindingProperties>

Author:

Warren Zhu

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 com.azure.spring.servicebus.stream.binder.ServiceBusMessageChannelBinder

bindingProperties, EXCEPTION_MESSAGE

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 and Description
ServiceBusQueueMessageChannelBinder(String[] headersToEmbed, ServiceBusChannelProvisioner provisioningProvider, com.azure.spring.integration.servicebus.queue.ServiceBusQueueOperation serviceBusQueueOperation)

Method Summary

Modifier and Type	Method and Description
protected org.springframework.integration.core.MessageProducer	createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties> properties)
protected org.springframework.messaging.MessageHandler	getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties> properties)

Methods inherited from class com.azure.spring.servicebus.stream.binder.ServiceBusMessageChannelBinder

buildCheckpointConfig, buildClientConfig, createProducerMessageHandler, getDefaultsPrefix, getErrorMessageStrategy, getExtendedConsumerProperties, getExtendedProducerProperties, getExtendedPropertiesEntryClass, setBindingProperties

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

afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, createProducerMessageHandler, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getApplicationEventPublisher, getContainerCustomizer, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandlerName, getErrorRecovererName, getMessageSourceCustomizer, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, postProcessOutputChannel, postProcessPollableSource, registerErrorInfrastructure, registerErrorInfrastructure, setApplicationEventPublisher, setConsumerEndpointCustomizer, setProducerMessageHandlerCustomizer, useNativeEncoding

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

afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getEvaluationContext, groupedName, onInit, 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

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

getBindings

Constructor Detail

ServiceBusQueueMessageChannelBinder

public ServiceBusQueueMessageChannelBinder(String[] headersToEmbed,
                                           @NonNull
                                           ServiceBusChannelProvisioner provisioningProvider,
                                           @NonNull
                                           com.azure.spring.integration.servicebus.queue.ServiceBusQueueOperation serviceBusQueueOperation)

Method Detail

createConsumerEndpoint

protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                                                      String group,
                                                                                      org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties> properties)

Specified by:

createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>,ServiceBusChannelProvisioner>

getErrorMessageHandler

protected org.springframework.messaging.MessageHandler getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                                              String group,
                                                                              org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties> properties)

Overrides:

getErrorMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<ServiceBusConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<ServiceBusProducerProperties>,ServiceBusChannelProvisioner>