Commit 5e696510 authored by xiaoyu's avatar xiaoyu
Browse files

rabbitmq交换机注释修改

parent f8f48322
...@@ -63,13 +63,13 @@ public class RabbitMqConfig { ...@@ -63,13 +63,13 @@ public class RabbitMqConfig {
return new Queue(CS.MQ.QUEUE_MODIFY_MCH_USER_REMOVE,true); return new Queue(CS.MQ.QUEUE_MODIFY_MCH_USER_REMOVE,true);
} }
//Fanout交换机 起名:fanoutExchange //创建 fanout 交换机
@Bean("fanoutExchange") @Bean("fanoutExchange")
FanoutExchange fanoutExchange() { FanoutExchange fanoutExchange() {
return new FanoutExchange(CS.FANOUT_EXCHANGE_SYS_CONFIG,true,false); return new FanoutExchange(CS.FANOUT_EXCHANGE_SYS_CONFIG,true,false);
} }
//交换机 起名:directExchange //创建 direct 交换机
@Bean("directExchange") @Bean("directExchange")
DirectExchange directExchange() { DirectExchange directExchange() {
return new DirectExchange(CS.DIRECT_EXCHANGE,true,false); return new DirectExchange(CS.DIRECT_EXCHANGE,true,false);
......
...@@ -44,7 +44,7 @@ public class RabbitMqConfig { ...@@ -44,7 +44,7 @@ public class RabbitMqConfig {
return new Queue(CS.MQ.TOPIC_MODIFY_MCH_APP,true); return new Queue(CS.MQ.TOPIC_MODIFY_MCH_APP,true);
} }
//交换机 起名:directExchange //创建 direct 交换机
@Bean("directExchange") @Bean("directExchange")
DirectExchange directExchange() { DirectExchange directExchange() {
return new DirectExchange(CS.DIRECT_EXCHANGE,true,false); return new DirectExchange(CS.DIRECT_EXCHANGE,true,false);
......
...@@ -46,7 +46,7 @@ public class RabbitMqConfig { ...@@ -46,7 +46,7 @@ public class RabbitMqConfig {
return new Queue(CS.MQ.QUEUE_PAYORDER_MCH_NOTIFY,true); return new Queue(CS.MQ.QUEUE_PAYORDER_MCH_NOTIFY,true);
} }
//Topic交换机 起名:testDirectExchange //创建 custom 交换机
@Bean @Bean
CustomExchange customExchange() { CustomExchange customExchange() {
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment