v4.7.3

Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>

Author: Keruspe

Cargo.lock

@@ -1,14 +1,14 @@
 [package]
 name = "lapin"
-version = "4.7.2"
+version = "4.7.3"
 edition = "2024"
 authors = ["Geoffroy Couprie <geo.couprie@gmail.com>", "Marc-Antoine Perennou <Marc-Antoine@Perennou.com>"]
 description = "AMQP client library"
 repository = "https://github.com/amqp-rs/lapin"
 readme = "README.md"
 documentation = "https://docs.rs/lapin"
-keywords = ["amqp", "rabbitmq", "mio", "futures"]
-categories = ["database"]
+keywords = ["amqp", "rabbitmq", "messaging", "async", "client"]
+categories = ["asynchronous", "network-programming"]
 license = "MIT"
 build = "build.rs"
 rust-version = "1.88.0"
@@ -124,5 +124,5 @@ required-features = ["smol"]
 name = "tokio"
 required-features = ["tokio"]
 
-[badges]
-maintenance = { status = "actively-developed" }
+[package.metadata.docs.rs]
+all-features = true

Cargo.toml

@@ -1,4 +1,6 @@
+Copyright (c) 2017-2026, Marc-Antoine Perennou <Marc-Antoine@Perennou.com>
 Copyright (c) 2017 Geoffroy Couprie
+All rights reserved.
 
 Permission is hereby granted, free of charge, to any person obtaining
 a copy of this software and associated documentation files (the

LICENSE

@@ -6,7 +6,7 @@
 [![Downloads](https://img.shields.io/crates/d/lapin.svg)](https://crates.io/crates/lapin)
 [![Coverage Status](https://coveralls.io/repos/github/amqp-rs/lapin/badge.svg?branch=main)](https://coveralls.io/github/amqp-rs/lapin?branch=main)
 [![Dependency Status](https://deps.rs/repo/github/amqp-rs/lapin/status.svg)](https://deps.rs/repo/github/amqp-rs/lapin)
-[![LICENSE](https://img.shields.io/badge/license-MIT-blue.svg)](LICENSE)
+[![LICENSE](https://img.shields.io/crates/l/lapin)](LICENSE)
 
  <strong>
    A Rust AMQP client library.

README.md

@@ -16,7 +16,7 @@ use tracing::trace;
 #[derive(Clone)]
 pub(crate) struct Acknowledgements(Arc<Mutex<Inner>>);
 
-type AMQPResult = std::result::Result<(), AMQPError>;
+type AMQPResult = Result<(), AMQPError>;
 
 impl Acknowledgements {
     pub(crate) fn new(channel_id: u16, returned_messages: ReturnedMessages) -> Self {

src/acknowledgement.rs

@@ -4,6 +4,7 @@ use crate::{
 };
 use amq_protocol::auth::{Credentials, SASLMechanism};
 use std::{
+    fmt,
     sync::{Mutex, MutexGuard},
     time::Duration,
 };
@@ -95,6 +96,7 @@ impl AuthProvider for DefaultAuthProvider {
 }
 
 /// OAuth2 token auth handler with expiry and refresh support
+#[derive(Debug)]
 pub struct TokenAuthProvider<TP: TokenProvider> {
     token_provider: TP,
     mechanism: SASLMechanism,
@@ -156,6 +158,12 @@ pub struct DefaultTokenProvider {
     token: Mutex<LongString>,
 }
 
+impl fmt::Debug for DefaultTokenProvider {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_struct("DefaultTokenProvider").finish_non_exhaustive()
+    }
+}
+
 impl DefaultTokenProvider {
     pub fn new<
         VF: Fn(&LongString) -> Option<Duration> + Send + Sync + 'static,

src/auth.rs

@@ -8,7 +8,7 @@ use std::{
 use tracing::error;
 
 #[derive(Clone)]
-pub struct Heartbeat<RK: RuntimeKit + Clone + Send + 'static> {
+pub(crate) struct Heartbeat<RK: RuntimeKit + Clone + Send + 'static> {
     connection_status: ConnectionStatus,
     killswitch: KillSwitch,
     runtime: Runtime<RK>,

src/heartbeat.rs

@@ -37,7 +37,7 @@ enum Status {
     Stop,
 }
 
-pub struct IoLoop<
+pub(crate) struct IoLoop<
     RK: RuntimeKit + Clone + Send + 'static,
     C: AsyncFn(AMQPUri, Runtime<RK>) -> Result<AsyncTcpStream<<RK as Reactor>::TcpStream>>
         + Send

src/io_loop.rs

@@ -1,4 +1,10 @@
-#![warn(rust_2018_idioms)]
+#![deny(missing_debug_implementations, unsafe_code)]
+#![warn(unreachable_pub, unused_qualifications, unused_lifetimes)]
+#![warn(
+    clippy::must_use_candidate,
+    clippy::unwrap_in_result,
+    clippy::panic_in_result_fn
+)]
 
 //! lapin
 //!

src/lib.rs

@@ -12,7 +12,7 @@ use std::{
 };
 
 #[derive(Default, Clone)]
-pub struct Notifier {
+pub(crate) struct Notifier {
     done: Arc<AtomicBool>,
     wakers: Wakers,
 }