我正在寻找示例代码,演示如何使用RabbitMQ消费消息,包括访问AMQP消息有效负载。
我试图从"consumer.rs“中运行"”示例,但我得到了以下内容
.ack(BasicAckOptions::default())
^^^ method not found in `(lapin::Channel, Delivery)
下面是从"“获得的代码
use futures_lite::StreamExt;
use lapin::{options::*, types::FieldTable, Connection, ConnectionProperties};
use