|
@@ -25,7 +25,10 @@ public class JmsConfig {
|
|
|
private String exchange;
|
|
|
|
|
|
@Value("${persagy.dmp.alarm.routingKey}")
|
|
|
- private String alarmRoutingKey;
|
|
|
+ private String dmpAlarmRoutingKey;
|
|
|
+
|
|
|
+ @Value("${alarm.obj.routingKey}")
|
|
|
+ private String alarmObjRoutingKey;
|
|
|
|
|
|
@Value("${persagy.dmp.rwd.routingKey}")
|
|
|
private String rwdRoutingKey;
|
|
@@ -33,6 +36,11 @@ public class JmsConfig {
|
|
|
@Value("${persagy.dmp.alarm.queue}")
|
|
|
private String alarmQueue;
|
|
|
|
|
|
+ /**
|
|
|
+ * 报警对象队列
|
|
|
+ */
|
|
|
+ private final String alarmObjQueue = "alarm-obj-queue";
|
|
|
+
|
|
|
@Autowired
|
|
|
private MessageProcesser messageProcesser;
|
|
|
|
|
@@ -48,7 +56,7 @@ public class JmsConfig {
|
|
|
|
|
|
@Bean
|
|
|
public Binding alarmBinding() {
|
|
|
- return BindingBuilder.bind(alarmQueue()).to(exchange()).with(alarmRoutingKey);
|
|
|
+ return BindingBuilder.bind(alarmQueue()).to(exchange()).with(dmpAlarmRoutingKey);
|
|
|
}
|
|
|
|
|
|
@Bean
|
|
@@ -56,11 +64,26 @@ public class JmsConfig {
|
|
|
return BindingBuilder.bind(alarmQueue()).to(exchange()).with(rwdRoutingKey);
|
|
|
}
|
|
|
|
|
|
+ @Bean
|
|
|
+ public Queue alarmObjQueue() {
|
|
|
+ return new Queue(alarmObjQueue, true);
|
|
|
+ }
|
|
|
|
|
|
- @RabbitListener(queues = "${persagy.dmp.alarm.queue}") //监听器监听指定的Queue
|
|
|
+ @Bean
|
|
|
+ public Binding alarmObjBinding() {
|
|
|
+ return BindingBuilder.bind(alarmObjQueue()).to(exchange()).with(alarmObjRoutingKey);
|
|
|
+ }
|
|
|
+
|
|
|
+ @RabbitListener(queues = alarmObjQueue) //监听器监听指定的Queue
|
|
|
public void process(String message, Channel channel, Message msg) {
|
|
|
log.info("============================== Receive:" + message);
|
|
|
DmpMessage dmpMessage = JacksonMapper.toObject(message, DmpMessage.class);
|
|
|
messageProcesser.listen(dmpMessage);
|
|
|
}
|
|
|
+
|
|
|
+ @RabbitListener(queues = "${persagy.dmp.alarm.queue}") //监听器监听指定的Queue
|
|
|
+ public void process(DmpMessage message) {
|
|
|
+ log.info("============================== Receive:" + JacksonMapper.toSimpleJson(message));
|
|
|
+ messageProcesser.listen(message);
|
|
|
+ }
|
|
|
}
|