This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new efe006ed [rust] remove is_started condition check because
telemetry_command_tx is suffice to tell (#711)
efe006ed is described below
commit efe006edf19aff9e9a13135266ea6dc5dfc824b0
Author: Qiping Luo <[email protected]>
AuthorDate: Mon Mar 18 14:11:59 2024 +0800
[rust] remove is_started condition check because telemetry_command_tx is
suffice to tell (#711)
---
rust/src/session.rs | 9 ---------
1 file changed, 9 deletions(-)
diff --git a/rust/src/session.rs b/rust/src/session.rs
index 7b2643c8..cd84f927 100644
--- a/rust/src/session.rs
+++ b/rust/src/session.rs
@@ -367,15 +367,6 @@ impl Session {
&mut self,
settings: TelemetryCommand,
) -> Result<(), ClientError> {
- if !self.is_started() {
- return Err(ClientError::new(
- ErrorKind::ClientIsNotRunning,
- "session is not started",
- OPERATION_UPDATE_SETTINGS,
- )
- .with_context("url", self.endpoints.endpoint_url()));
- }
-
if let Some(tx) = self.telemetry_tx.as_ref() {
tx.send(settings).await.map_err(|e| {
ClientError::new(
