calling close on amqp protocol object , generates infinite loop.

[aneeshkp]

When calling close on protocol

func (t *Protocol) Close(ctx context.Context) (err error) {

The code goes on an infinite loop

client/client.go line 244
if err != nil {
					cecontext.LoggerFrom(ctx).Warn("Error while receiving a message: ", err)
					continue
}

With error

go:244","msg":"Error while receiving a message: amqp: link closed"}
{"level":"warn","ts":1620052511.8445728,"logger":"fallback","caller":"client/client.go:244","msg":"Error while receiving a message: amqp: link closed"}