From e3e0d05cf91d76778535f1f81e4bcdd17e3478c5 Mon Sep 17 00:00:00 2001 From: Magnus Landerblom Date: Thu, 26 Sep 2024 18:29:15 +0200 Subject: [PATCH] fix --- src/lavinmq/vhost.cr | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/lavinmq/vhost.cr b/src/lavinmq/vhost.cr index e520e54cc..db8b9723b 100644 --- a/src/lavinmq/vhost.cr +++ b/src/lavinmq/vhost.cr @@ -123,6 +123,9 @@ module LavinMQ ex = @exchanges[msg.exchange_name]? || return false published_queue_count = ex.publish(msg, immediate, found_queues, visited) !published_queue_count.zero? + ensure + visited.clear + found_queues.clear end def details_tuple