don't loop when sending lag to ack channel

cloudamqp · Oct 31, 2023 · 3ea75bf · 3ea75bf
1 parent e125e67
commit 3ea75bf
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/lavinmq/replication/server.cr b/src/lavinmq/replication/server.cr
@@ -227,8 +227,7 @@ module LavinMQ
             @acked_bytes += len
             if max_lag = Config.instance.max_lag
               if lag < max_lag
-                while @ack.try_send lag
-                end
+                @ack.try_send lag
               end
             end
           end