程序包 | 说明 |
---|---|
wang.bigbird.domain.framework.data.rocketmq | |
wang.bigbird.domain.framework.data.rocketmq.base.helper |
限定符和类型 | 方法和说明 |
---|---|
org.apache.rocketmq.client.producer.DefaultMQProducer |
RocketmqConfiguration.defaultMQProducer(RocketmqProducerProperties rocketmqProducerProperties,
RocketmqConsumerProperties rocketmqConsumerProperties,
org.apache.rocketmq.spring.autoconfigure.RocketMQProperties springRocketmqProperties) |
限定符和类型 | 方法和说明 |
---|---|
static void |
PropertiesHelper.combineRocketmqProperties(RocketmqProducerProperties rocketmqProducerProperties,
RocketmqConsumerProperties rocketmqConsumerProperties,
org.apache.rocketmq.spring.autoconfigure.RocketMQProperties springRocketmqProperties)
合并rocketmq配置
配置加载优先级如下:
1、自定义配置优先
2、spring原生配置作为候补
|
static org.apache.rocketmq.client.producer.DefaultMQProducer |
MQProducerHelper.createDefaultMQProducer(String producerGroupName,
RocketmqProducerProperties rocketmqProducerProperties)
创建消息生产者
|