diff --git a/downstream.go b/downstream.go index 95d9400..477e325 100644 --- a/downstream.go +++ b/downstream.go @@ -693,13 +693,12 @@ func (dc *downstreamConn) welcome() error { } for { - msg := consumer.Peek() + msg := consumer.Consume() if msg == nil { break } dc.sendFromUpstream(msg, uc) - consumer.Consume() } })