|
@@ -2,11 +2,9 @@ package com.persagy.dmp.alarm.jms;
|
|
|
|
|
|
import com.persagy.common.json.JacksonMapper;
|
|
|
import com.persagy.dmp.rwd.model.DmpMessage;
|
|
|
+import com.rabbitmq.client.Channel;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
-import org.springframework.amqp.core.Binding;
|
|
|
-import org.springframework.amqp.core.BindingBuilder;
|
|
|
-import org.springframework.amqp.core.Queue;
|
|
|
-import org.springframework.amqp.core.TopicExchange;
|
|
|
+import org.springframework.amqp.core.*;
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
@@ -58,9 +56,11 @@ public class JmsConfig {
|
|
|
return BindingBuilder.bind(alarmQueue()).to(exchange()).with(rwdRoutingKey);
|
|
|
}
|
|
|
|
|
|
+
|
|
|
@RabbitListener(queues = "${persagy.dmp.alarm.queue}") //监听器监听指定的Queue
|
|
|
- public void process(DmpMessage message) {
|
|
|
- log.info("============================== Receive:" + JacksonMapper.toSimpleJson(message));
|
|
|
- messageProcesser.listen(message);
|
|
|
+ public void process(String message, Channel channel, Message msg) {
|
|
|
+ log.info("============================== Receive:" + message);
|
|
|
+ DmpMessage dmpMessage = JacksonMapper.toObject(message, DmpMessage.class);
|
|
|
+ messageProcesser.listen(dmpMessage);
|
|
|
}
|
|
|
}
|