注释取消

guoshilong

2024-03-23 dba799945f9f74f85614fa6e2695f06dd8cb7abc

注释取消

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

@@ -18,12 +18,12 @@
@AllArgsConstructor
public class MyRabbitReceiver {
    private final IAlarmGetService alarmGetService;
//
//    @RabbitListener(queues = "alarm")
//    public void processMessage(Message message) {
//        System.out.println("收到消息"+new String(message.getBody()));
//        AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
//        alarmGetService.save(alarmGet);
//    }

    @RabbitListener(queues = "alarm")
    public void processMessage(Message message) {
        System.out.println("收到消息"+new String(message.getBody()));
        AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
        alarmGetService.save(alarmGet);
    }

}