com.azure.spring.servicebus.stream.binder.config

Class ServiceBusQueueBinderConfiguration

java.lang.Object

com.azure.spring.servicebus.stream.binder.config.ServiceBusQueueBinderConfiguration

@Configuration
 @ConditionalOnMissingBean(value=org.springframework.cloud.stream.binder.Binder.class)
 @Import(value={com.azure.spring.cloud.autoconfigure.context.AzureEnvironmentAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.context.AzureContextAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusQueueAutoConfiguration.class,ServiceBusQueueBinderHealthIndicatorConfiguration.class})
 @EnableConfigurationProperties(value={com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusProperties.class,ServiceBusQueueExtendedBindingProperties.class})
public class ServiceBusQueueBinderConfiguration
extends Object

Author:

Warren Zhu

Constructor Summary

Constructors

Constructor and Description
ServiceBusQueueBinderConfiguration()

Method Summary

Modifier and Type	Method and Description
ServiceBusChannelProvisioner	serviceBusChannelProvisioner(com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusProperties serviceBusProperties, com.azure.spring.cloud.context.core.impl.ServiceBusNamespaceManager serviceBusNamespaceManager, com.azure.spring.cloud.context.core.impl.ServiceBusQueueManager serviceBusQueueManager)
ServiceBusQueueMessageChannelBinder	serviceBusQueueBinder(ServiceBusChannelProvisioner queueChannelProvisioner, com.azure.spring.integration.servicebus.queue.ServiceBusQueueOperation serviceBusQueueOperation, ServiceBusQueueExtendedBindingProperties bindingProperties)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceBusQueueBinderConfiguration

public ServiceBusQueueBinderConfiguration()

Method Detail

serviceBusChannelProvisioner

@Bean
 @ConditionalOnMissingBean
public ServiceBusChannelProvisioner serviceBusChannelProvisioner(com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusProperties serviceBusProperties,
                                                                                                  @Autowired(required=false)
                                                                                                  com.azure.spring.cloud.context.core.impl.ServiceBusNamespaceManager serviceBusNamespaceManager,
                                                                                                  @Autowired(required=false)
                                                                                                  com.azure.spring.cloud.context.core.impl.ServiceBusQueueManager serviceBusQueueManager)

serviceBusQueueBinder

@Bean
public ServiceBusQueueMessageChannelBinder serviceBusQueueBinder(ServiceBusChannelProvisioner queueChannelProvisioner,
                                                                       com.azure.spring.integration.servicebus.queue.ServiceBusQueueOperation serviceBusQueueOperation,
                                                                       ServiceBusQueueExtendedBindingProperties bindingProperties)