Modify max_retries to 1

rmqtt · Sep 29, 2022 · f291f4d · f291f4d
1 parent e4c91f1
commit f291f4d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/raft_node.rs b/src/raft_node.rs
@@ -829,8 +829,8 @@ impl<S: Store + 'static> RaftNode<S> {
                 client,
                 client_id,
                 chan: self.snd.clone(),
-                max_retries: 0,
-                timeout: Duration::from_millis(300),
+                max_retries: 1,
+                timeout: Duration::from_millis(500),
             };
             // if let Err(e) = self.msg_tx.try_send(message_sender) {
             //     log::warn!("msg_tx.try_send, error: {:?}", e.to_string());