Disconnect on error from service readiness check

ntex-rs · Oct 15, 2024 · ed239f6 · ed239f6
1 parent 5bf8f07
commit ed239f6
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [4.1.1] - 2024-10-15
+
+* Disconnect on error from service readiness check
+
 ## [4.1.0] - 2024-10-10
 
 * Do not check readiness for call

diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-mqtt"
-version = "4.1.0"
+version = "4.1.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Client and Server framework for MQTT v5 and v3.1.1 protocols"
 documentation = "https://docs.rs/ntex-mqtt"

diff --git a/src/io.rs b/src/io.rs
@@ -489,11 +489,11 @@ where
  }
  // handle service readiness error
  Poll::Ready(Err(err)) => {
- log::trace!("{}: Service readiness check failed, stopping", self.io.tag());
+ log::error!("{}: Service readiness check failed, stopping", self.io.tag());
  self.st = IoDispatcherState::Stop;
  self.flags.insert(Flags::READY_ERR);
  self.state.borrow_mut().error = Some(IoDispatcherError::Service(err));
- Poll::Ready(PollService::Continue)
+ Poll::Ready(PollService::Item(DispatchItem::Disconnect(None)))
  }
  }
  }