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.servicebus.AzureServiceBusQueueAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.context.AzureEnvironmentAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.context.AzureContextAutoConfiguration.class,com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusAutoConfiguration.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
void	collectTelemetry()
ServiceBusChannelProvisioner	serviceBusChannelProvisioner(com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusProperties serviceBusProperties)
ServiceBusChannelProvisioner	serviceBusChannelProvisionerWithResourceManagerProvider()
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

collectTelemetry

@PostConstruct
public void collectTelemetry()

serviceBusChannelProvisioner

@Bean
 @ConditionalOnBean(value=com.azure.spring.cloud.context.core.api.ResourceManagerProvider.class)
 @ConditionalOnMissingBean
public ServiceBusChannelProvisioner serviceBusChannelProvisioner(com.azure.spring.cloud.autoconfigure.servicebus.AzureServiceBusProperties serviceBusProperties)

serviceBusChannelProvisionerWithResourceManagerProvider

@Bean
 @ConditionalOnMissingBean(value={com.azure.spring.cloud.context.core.api.ResourceManagerProvider.class,com.azure.spring.servicebus.stream.binder.provisioning.ServiceBusChannelProvisioner.class})
public ServiceBusChannelProvisioner serviceBusChannelProvisionerWithResourceManagerProvider()

serviceBusQueueBinder

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