org.springframework.cloud.stream.binder.rocketmq.config

Class RocketMQBinderAutoConfiguration

java.lang.Object

org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderAutoConfiguration

@Configuration
 @EnableConfigurationProperties(value={RocketMQBinderConfigurationProperties.class,RocketMQExtendedBindingProperties.class})
public class RocketMQBinderAutoConfiguration
extends Object

Author:

Timur Valiev, Jim

Constructor Summary

Constructors

Constructor and Description
RocketMQBinderAutoConfiguration(RocketMQExtendedBindingProperties extendedBindingProperties, RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties)

Method Summary

Modifier and Type	Method and Description
ConsumersManager	consumersManager()
RocketMQTopicProvisioner	provisioningProvider()
RocketMQMessageChannelBinder	rocketMessageChannelBinder(RocketMQTopicProvisioner provisioningProvider, ConsumersManager consumersManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

RocketMQBinderAutoConfiguration

@Autowired
public RocketMQBinderAutoConfiguration(RocketMQExtendedBindingProperties extendedBindingProperties,
                                                  RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties)

Method Detail

provisioningProvider

@Bean
public RocketMQTopicProvisioner provisioningProvider()

rocketMessageChannelBinder

@Bean
public RocketMQMessageChannelBinder rocketMessageChannelBinder(RocketMQTopicProvisioner provisioningProvider,
                                                                     ConsumersManager consumersManager)

consumersManager

@Bean
public ConsumersManager consumersManager()