Try resending from queue on message send only if successful (#102)

Nuffle-Labs · Apr 22, 2024 · 09db79b · 09db79b
1 parent 3093642
commit 09db79b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/operator/rpc_client.go b/operator/rpc_client.go
@@ -162,14 +162,14 @@ func (c *AggregatorRpcClient) sendOperatorMessage(sendCb func() error, message R
 		return
 	}
 
-	c.tryResendFromDeque()
-
 	c.logger.Info("Sending request to aggregator")
 	err = sendCb()
 	if err != nil {
 		appendProtected()
 		return
 	}
+
+	c.tryResendFromDeque()
 }
 
 func (c *AggregatorRpcClient) sendRequest(sendCb func() error) error {