mq还原

guoshilong

2023-08-07 e45dae20b3ce4b13976d65c7803a4b62d42e3a1c

mq还原

 skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java

@@ -22,10 +22,10 @@
    @RabbitListener(queues = "alarm")
    public void processMessage(Message message) {

//        AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
//        alarmGetService.save(alarmGet);
//
//        System.out.println("收到消息"+new String(message.getBody()));
        AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
        alarmGetService.save(alarmGet);

        System.out.println("收到消息"+new String(message.getBody()));
    }

}