Closed peterbourgon closed 11 years ago
Running a test that looks like:
base := make([]byte, 1e5)
for i := 0; i < len(base); i++ {
ch.Publish("", queue, false, false, Publishing{Body: base[0:i]})
}
I am unable to reproduce a panic at https://github.com/streadway/amqp/blob/9515743a136dbef5e14191dee1a02337ff337e97/channel.go#L237
@peterbourgon have you seen this error again?
Alas, no. I'm setting up another high-load scenario early next week. If it happens again I will try to produce a better test case.
I have an application that creates a single connection + channel, and serializes a ton of publishings onto it. When I publish it looks like this:
Sometimes during high load I am experiencing crashes which look like this:
Please let me know if that's not enough to go on -- with some effort I may be able to build a minimal test case.