【发布时间】:2019-04-17 07:23:36
【问题描述】:
从 AmqpReceiver,我可以打印出入队消息,但是如何从队列中出列或清除消息?
amqpClient.createReceiver("my-queue",
done -> {
if (done.failed()) {
done.cause().printStackTrace();
System.out.println("Unable to create receiver");
} else {
final AmqpReceiver receiver = done.result();
receiver.address();
receiver
.exceptionHandler(t -> {
t.printStackTrace();
})
.handler(msg -> {
System.out.println("Message: " + msg.bodyAsJsonObject().toString());
});
receiver.connection().close(ar -> {
});
}
}
);
【问题讨论】:
-
到目前为止你尝试过什么(代码)?这鼓励回答...
-
我添加了代码,实际上我参考了这个链接vertx.io/docs/vertx-amqp-client/java,但只是卡住了消息没有出队。