From a755dca8e95a37a55e71bcd5570dff5b7aca9b95 Mon Sep 17 00:00:00 2001
From: Michael Klishin <michael@clojurewerkz.org>
Date: Tue, 18 May 2021 14:35:48 +0300
Subject: [PATCH] MQTT: use consistent Ra operation timeout values

of more than the default 5s which is really low.
---
 deps/rabbitmq_mqtt/src/mqtt_node.erl | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/deps/rabbitmq_mqtt/src/mqtt_node.erl b/deps/rabbitmq_mqtt/src/mqtt_node.erl
index 8d27e6e2e1..f2f6b04ee1 100644
--- a/deps/rabbitmq_mqtt/src/mqtt_node.erl
+++ b/deps/rabbitmq_mqtt/src/mqtt_node.erl
@@ -66,7 +66,7 @@ start(Delay, AttemptsLeft) ->
           _ ->
               join_peers(NodeId, Nodes),
               ra:restart_server(?RA_SYSTEM, NodeId),
-              ra:trigger_election(NodeId)
+              ra:trigger_election(NodeId, ?RA_OPERATION_TIMEOUT)
     end,
     ok.
 
@@ -90,7 +90,7 @@ start_server() ->
     ra:start_server(?RA_SYSTEM, Conf).
 
 trigger_election() ->
-    ra:trigger_election(server_id()).
+    ra:trigger_election(server_id(), ?RA_OPERATION_TIMEOUT).
 
 join_peers(_NodeId, []) ->
     ok;