Skip to content

Commit c0799d8

Browse files
committed
derecated Acker::default()
1 parent 6130cd8 commit c0799d8

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

examples/publisher_confirms.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,7 @@ fn main() {
124124
.expect("publisher-confirms");
125125
assert!(confirm.is_ack());
126126
let message = confirm.take_message().unwrap();
127+
let acker = message.delivery.acker.clone();
127128
assert_eq!(
128129
message,
129130
BasicReturnMessage {
@@ -134,7 +135,7 @@ fn main() {
134135
redelivered: false,
135136
properties: BasicProperties::default().with_priority(42),
136137
data: payload.to_vec(),
137-
acker: Default::default(),
138+
acker,
138139
},
139140
reply_code: 312,
140141
reply_text: "NO_ROUTE".into(),

src/acker.rs

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,12 +7,13 @@ use crate::{
77
Error, Promise, PromiseResolver, Result,
88
};
99

10+
use tracing::warn;
1011
use std::sync::{
1112
atomic::{AtomicBool, Ordering},
1213
Arc,
1314
};
1415

15-
#[derive(Clone, Default, Debug)]
16+
#[derive(Clone, Debug)]
1617
pub struct Acker {
1718
channel_id: ChannelId,
1819
delivery_tag: DeliveryTag,
@@ -100,6 +101,14 @@ impl Acker {
100101
}
101102
}
102103

104+
// FIXME: remove in 3.0
105+
impl Default for Acker {
106+
fn default() -> Self {
107+
warn!("Use of deprecated Acker::default() which provides an unusable Acker");
108+
Self::new(0, 0, None, None)
109+
}
110+
}
111+
103112
impl PartialEq for Acker {
104113
fn eq(&self, other: &Acker) -> bool {
105114
self.channel_id == other.channel_id && self.delivery_tag == other.delivery_tag

0 commit comments

Comments
 (0)