streadway / amqp

Go client for AMQP 0.9.1
http://godoc.org/github.com/streadway/amqp
BSD 2-Clause "Simplified" License
4.88k stars 621 forks source link

Error consuming from a queue that contains data packaged with msgpack #538

Open abbas-unitary opened 1 year ago

abbas-unitary commented 1 year ago

My application consumes from a queue that contains messages packaged with msgpack. When channel.Consume is called, the rabbitmq server drops the connection, and channel.NotifyClose returns the following error "error":"Exception (501) Reason: \"Exception (502) Reason: \\\"invalid field or value inside of a frame\\\"\"". This error seems to occur in some queues and not in others, and the configuration of all the queues is the same. I don't expect the msgpack encoding to be the problem, but I am unable to get to the bottom of this. Any thoughts?