We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7a0b52c commit 6bb211cCopy full SHA for 6bb211c
src/lavinmq/amqp/queue/queue.cr
@@ -220,6 +220,8 @@ module LavinMQ::AMQP
220
@paused = BoolChannel.new(false)
221
@consumers_empty = BoolChannel.new(true)
222
@single_active_consumer_change = ::Channel(Client::Channel::Consumer).new
223
+ @unacked_count.set(0u32, :relaxed)
224
+ @unacked_bytesize.set(0u64, :relaxed)
225
end
226
227
# own method so that it can be overriden in other queue implementations
0 commit comments