Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
snichme committed Sep 26, 2024
1 parent 7c5b127 commit e3e0d05
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/lavinmq/vhost.cr
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit e3e0d05

Please sign in to comment.