巡查修改

guoshilong

2024-03-23 f04487fef5ac47380dfa9670156743c9d273966b

 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);
//   }

}