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