package com.yeshi.buwan.util.mq.rabbit;
|
|
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.core.MessageListener;
|
|
import java.io.UnsupportedEncodingException;
|
|
/**
|
* @author hxh
|
* @title: QueueHelloWorldListener
|
* @description: 测试消息
|
* @date 2024/9/26 13:47
|
*/
|
public class QueueHelloWorldListener implements MessageListener {
|
@Override
|
public void onMessage(Message message) {
|
try {
|
System.out.println("收到消息："+ new String(message.getBody(),"UTF-8"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
