thothothotho

Other possibilities. To enforce that some parameters are mandatory ```go r.channel.QueueDeclare("foo", amqp.AutoDelete) ``` where ```go type Option func(interface{}) var AutoDelete Option = func(v interface{}) { opts := v.(*queueDeclare) opts.AutoDelete =...

In fact `ch.consumers.add` implement an infinite buffered channel (which could be an issue on its own: #489 ) So adding a buffer here would not change anything.

That makes the basic API very unfriendly and dangerous. And your patch against ExecuteScalar does not help if the request ends with ```sql … RETURNING (id, created_at) ``` In which...

If I make a query that returns a thousand of rows + a final error that basically invalidate all the rows I have just processed, then I would not mind...

got the same issue with [email protected] on prod when we lost our kafka: ``` panic: runtime error: invalid memory address or nil pointer dereference [signal SIGSEGV: segmentation violation code=0x1 addr=0x10...