Infinite loop on AMQP disconnect

[canni]

Currently there's no way to prevent infinite loop here:

sdk-go/v2/client/client.go

Line 255 in 04ed212

cecontext.LoggerFrom(ctx).Warn("Error while receiving a message: ", err)

In my case if my connection to AMQP broker dies the continue statement a line below the mentioned above just spins the loop indefinitely.

(My broker is RabbitMQ + AMQP 1.0 plugin)

[embano1]

Interesting, so this is not covered by io.EOF it seems. Do you see the error/error type thrown that we could assert on?

[canni]

Here's an error string from my logs:
Error while receiving a message: *Error{Condition: amqp:internal-error, Description: Connection forced: ... (Shortened output)

[canni]

After a bit more digging, this in the error returned: https://github.com/Azure/go-amqp/blob/v0.17.0/errors.go#L14
It might be a buggy AMQP1 impl from Rabbit's plugin perspective, but IMO InternalErr from AMQP client shouldn't continue processing :)