Commit 2b67011d authored by Камалов Эрик's avatar Камалов Эрик :zzz:
Browse files

s

Showing with 1 addition and 0 deletions
+1 -0
......@@ -82,6 +82,7 @@ func (channel *Channel) Consume(queue, consumer string, autoAck, exclusive, noLo
case msg, ok := <-messages:
{
if !ok {
time.Sleep(100 * time.Millisecond)
continue
}
var attempt = 0
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment