Merge branch 'jtdev' of https://hbsl-code.gistack.cn/hbwri/manager into jtdev

zhongrj

2023-08-07 50bc6ee76ffcebc0b539e0fb5698a3911e5f6c02

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

@@ -1,5 +1,9 @@
package cn.gistack.nky.rabbitmq;

import cn.gistack.nky.entity.AlarmGet;
import cn.gistack.nky.service.IAlarmGetService;
import com.alibaba.fastjson.JSONObject;
import lombok.AllArgsConstructor;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@@ -11,11 +15,17 @@
 * @DATE: 2023/8/3 15:54
 */
@Component
@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);
//
//      System.out.println("收到消息"+new String(message.getBody()));
   }

}