解决错误信息
This commit is contained in:
@@ -28,7 +28,7 @@ public class Consumer {
|
||||
Channel channel = connection.createChannel();
|
||||
|
||||
DeliverCallback deliverCallback = (coustomerTag, message) -> {
|
||||
System.out.println(new String(message.getBody())q);
|
||||
System.out.println(new String(message.getBody()));
|
||||
};
|
||||
|
||||
CancelCallback cancelCallback = (coustomerTag) -> {
|
||||
|
Reference in New Issue
Block a user