Skip to content

Commit

Permalink
Merge pull request #107 from julianbraha/main
Browse files Browse the repository at this point in the history
Fix "delcare_ok" typo
  • Loading branch information
gftea authored Sep 18, 2023
2 parents 0a9c635 + e1c3856 commit bba6804
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions amqprs/src/api/channel/queue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -389,17 +389,17 @@ impl Channel {
Ok(None)
} else {
let responder_rx = self.register_responder(DeclareQueueOk::header()).await?;
let delcare_ok = synchronous_request!(
let declare_ok = synchronous_request!(
self.shared.outgoing_tx,
(self.channel_id(), declare.into_frame()),
responder_rx,
Frame::DeclareQueueOk,
Error::ChannelUseError
)?;
Ok(Some((
delcare_ok.queue.into(),
delcare_ok.message_count,
delcare_ok.consumer_count,
declare_ok.queue.into(),
declare_ok.message_count,
declare_ok.consumer_count,
)))
}
}
Expand Down

0 comments on commit bba6804

Please sign in to comment.