Tune idle timeout (#55)

Author: fafhrd91

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [3.0.2] - 2024-06-27
+
+* Tune idle timeout
+
 ## [3.0.1] - 2024-06-04
 
 * Better handling "session end" for inflight deliveries

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-amqp"
-version = "3.0.1"
+version = "3.0.2"
 authors = ["ntex contributors <[email protected]>"]
 description = "AMQP 1.0 Client/Server framework"
 documentation = "https://docs.rs/ntex-amqp"

src/dispatcher.rs

@@ -1,7 +1,6 @@
 use std::collections::VecDeque;
-use std::{
-    cell, future::poll_fn, future::Future, marker, pin::Pin, rc::Rc, task::Context, task::Poll,
-};
+use std::task::{Context, Poll};
+use std::{cell, cmp, future::poll_fn, future::Future, marker, pin::Pin, rc::Rc};
 
 use ntex::service::{Pipeline, PipelineBinding, PipelineCall, Service, ServiceCtx};
 use ntex::time::{sleep, Millis, Sleep};
@@ -48,6 +47,7 @@ where
         ctl_service: Pipeline<Ctl>,
         idle_timeout: Millis,
     ) -> Self {
+        let idle_timeout = Millis(cmp::min(idle_timeout.0 >> 1, 1000));
         let ctl_queue = sink.get_control_queue().clone();
         Dispatcher {
             sink,

src/sndlink.rs

@@ -235,7 +235,7 @@ impl SenderLinkInner {
     }
 
     pub(crate) fn remote_detached(&mut self, err: AmqpProtocolError) {
-        log::error!(
+        log::trace!(
             "{}: Detaching sender link {:?} with error {:?}",
             self.session.tag(),
             self.name,