监听的代码改成这样试试
public class RabbitMqListener implements MessageListener {
@Override
public void onMessage(Message message) {
try {
String str = new String(message.getBody());
// TODO 接受消息
System.out.println(message.getMessageProperties().getMessageId());
System.out.println("Recived msg:" + str);
} catch (Exception e) {
// TODO: handle exception
}
}
}
内容全部来源于网络收集，如有侵权，请联系网站删除：QQ：24596024