diff --git a/src/delivery.rs b/src/delivery.rs index f4dbcdb..e2668cb 100644 --- a/src/delivery.rs +++ b/src/delivery.rs @@ -134,7 +134,7 @@ impl Delivery { } pub async fn wait(&self) -> Result, AmqpProtocolError> { - if self.0.flags.get().contains(Flags::LOCAL_SETTLED) { + if self.flags.get().contains(Flags::LOCAL_SETTLED) { return Ok(None); }