提交 8e47f623 authored 作者: 艾庆国's avatar 艾庆国

运单预警

上级 23da6dc7
...@@ -32,11 +32,13 @@ public class RabbitVehicleWarnConfig { ...@@ -32,11 +32,13 @@ public class RabbitVehicleWarnConfig {
params.put("x-max-length", 5000000); params.put("x-max-length", 5000000);
params.put("x-dead-letter-exchange", RabbitKeyVehicleWarnConstants.DEFAULT_EXCHANGE); params.put("x-dead-letter-exchange", RabbitKeyVehicleWarnConstants.DEFAULT_EXCHANGE);
params.put("x-dead-letter-routing-key", RabbitKeyVehicleWarnConstants.DEFAULT_DEAD_ROUTING_KEY); params.put("x-dead-letter-routing-key", RabbitKeyVehicleWarnConstants.DEFAULT_DEAD_ROUTING_KEY);
return new Queue(RabbitKeyVehicleWarnConstants.DEFAULT_DELAY_QUEUE, true, false, false, params); return new Queue(RabbitKeyVehicleWarnConstants.DEFAULT_DELAY_QUEUE,
true, false, false, params);
} }
@Bean @Bean
public Binding vehicleWarnDefaultDelayQueueBinding() { public Binding vehicleWarnDefaultDelayQueueBinding() {
return BindingBuilder.bind(vehicleWarnDefaultDelayQueue()).to(vehicleWarnDefaultExchange()).with(RabbitKeyVehicleWarnConstants.DEFAULT_DELAY_ROUTING_KEY); return BindingBuilder.bind(vehicleWarnDefaultDelayQueue()).to(vehicleWarnDefaultExchange())
.with(RabbitKeyVehicleWarnConstants.DEFAULT_DELAY_ROUTING_KEY);
} }
@Bean @Bean
...@@ -45,7 +47,8 @@ public class RabbitVehicleWarnConfig { ...@@ -45,7 +47,8 @@ public class RabbitVehicleWarnConfig {
} }
@Bean @Bean
public Binding vehicleWarnDefaultDeadQueueBinding() { public Binding vehicleWarnDefaultDeadQueueBinding() {
return BindingBuilder.bind(vehicleWarnDefaultDeadQueue()).to(vehicleWarnDefaultExchange()).with(RabbitKeyVehicleWarnConstants.DEFAULT_DEAD_ROUTING_KEY); return BindingBuilder.bind(vehicleWarnDefaultDeadQueue()).to(vehicleWarnDefaultExchange())
.with(RabbitKeyVehicleWarnConstants.DEFAULT_DEAD_ROUTING_KEY);
} }
...@@ -58,7 +61,8 @@ public class RabbitVehicleWarnConfig { ...@@ -58,7 +61,8 @@ public class RabbitVehicleWarnConfig {
} }
@Bean @Bean
public Binding vehicleWarnChildAddQueueBinding() { public Binding vehicleWarnChildAddQueueBinding() {
return BindingBuilder.bind(vehicleWarnChildAddQueue()).to(vehicleWarnDefaultExchange()).with(RabbitKeyVehicleWarnConstants.ORDER_CHILD_ADD_ROUTING_KEY); return BindingBuilder.bind(vehicleWarnChildAddQueue()).to(vehicleWarnDefaultExchange())
.with(RabbitKeyVehicleWarnConstants.ORDER_CHILD_ADD_ROUTING_KEY);
} }
/** /**
...@@ -70,7 +74,8 @@ public class RabbitVehicleWarnConfig { ...@@ -70,7 +74,8 @@ public class RabbitVehicleWarnConfig {
} }
@Bean @Bean
public Binding vehicleWarnTruckWarnQueueBinding() { public Binding vehicleWarnTruckWarnQueueBinding() {
return BindingBuilder.bind(vehicleWarnTruckWarnQueue()).to(vehicleWarnDefaultExchange()).with(RabbitKeyVehicleWarnConstants.TRUCK_WARN_ROUTING_KEY); return BindingBuilder.bind(vehicleWarnTruckWarnQueue()).to(vehicleWarnDefaultExchange())
.with(RabbitKeyVehicleWarnConstants.TRUCK_WARN_ROUTING_KEY);
} }
/** /**
* 车辆预警 * 车辆预警
...@@ -81,7 +86,8 @@ public class RabbitVehicleWarnConfig { ...@@ -81,7 +86,8 @@ public class RabbitVehicleWarnConfig {
} }
@Bean @Bean
public Binding vehicleWarnNoticeQueueBinding() { public Binding vehicleWarnNoticeQueueBinding() {
return BindingBuilder.bind(vehicleWarnNoticeQueue()).to(vehicleWarnDefaultExchange()).with(RabbitKeyVehicleWarnConstants.TRUCK_WARN_NOTICE_ROUTING_KEY); return BindingBuilder.bind(vehicleWarnNoticeQueue()).to(vehicleWarnDefaultExchange())
.with(RabbitKeyVehicleWarnConstants.TRUCK_WARN_NOTICE_ROUTING_KEY);
} }
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论