cony

cony copied to clipboard

https://github.com/rabbitmq/amqp091-go is maintained by the RabbitMQ core team and should replace streadway/amqp.

Gobd

https://github.com/assembla/cony/blob/dd62697b0adb9adfda8589520cb85f4cbc2361f1/consumer.go#L76 I find i can't set queue ttl, which set by args 'x-expires'

sunfuze

latest commit was Dec 21, 2016 should we assume this project is no longer active?

peczenyj

Consumer send on closed channel after Cancel

3

Hi, I got multiple errors when trying to close a Consumer using Cancel: The c.deliveries channel is closed in the Cancel method, but than the serve method, because of the...

cdeluce

Sometimes, I find that this publish function is invalid. I can't send messages using this function, but I don't know where the cause is. Add a return parameter (error) to...

somnus-L

Declare passive

7

* Update declarer interface with new passive methods * Add DeclareQueuePassive * Add DeclareExchangePassive * Add tests for new methods Allow users to test for the existence of a queue.

steviebiddles

Handling prefetched messages upon lost connection?

3

Awesome package, this helps us a lot. Just one question that's come up while testing various edge cases: If prefetch is set to > 1, then you could conceivably have...

jraede

Inspect message and consumer counts for a queue.

6

re #34

phensley

fari-99