增加接收消息队列信息

xieb

2023-08-03 d3c4e4780bab533337a5261bc09350af51f76740

增加接收消息队列信息

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

New file
@@ -0,0 +1,21 @@
package cn.gistack.nky.rabbitmq;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION: 接收南科院消息队列
 * @USER: aix
 * @DATE: 2023/8/3 15:54
 */
@Component
public class MyRabbitReceiver {

    @RabbitListener(queues = "alarm")
    public void processMessage(Message message) {
        System.out.println("收到消息"+new String(message.getBody()));
    }

}