wagslane/go-rabbitmq
A wrapper of streadway/amqp that provides reconnection logic and sane defaults
GoMIT
Issues
- 0
Can consumer support temporary queues?
#167 opened by guodongq - 0
- 0
reconnection error: error reconnecting to amqp server: Exception (504) Reason: "channel/connection is not open"
#164 opened by minhyannv - 2
reconnection bug
#162 opened by yunxu0604 - 12
memory leak
#149 opened by lmb1113 - 1
- 2
Declare queue without consuming messages
#142 opened by danikk741 - 0
Asynchronous reconnection
#160 opened by timandy - 2
- 3
Support for RabbitMQ Clusters
#148 opened by angelokurtis - 1
Support for Dead Letter Exchange
#140 opened by Mokto - 0
Docs specify `WithPublisherOptionsExchangeDeclare` *stops* this library from declaring the exchanges existance
#153 opened by Nikola-Milovic - 1
- 1
only reconnecting some consumers
#137 opened by MaxBreida - 1
- 1
My business requires batch processing of messages. Currently, the Consumer can only provide one callback at a time. Can I open up chan (msgs)? I want to handle message callbacks myself
#143 opened by pzhu1015 - 0
how to gracefully shutdown mq consumers?
#151 opened by eric-chao - 2
Reasonable default for QOS prefetch?
#113 opened by ae-govau - 1
received 'direct' but current is 'topic'"
#144 opened by fighterhit - 3
Remove Tracef logger requirement
#123 opened by JarlMartinez - 5
Retry Publish Option
#134 opened by gnuletik - 1
Cluster support
#141 opened by ggalihpp-jubelio - 2
Direct reply-to
#135 opened by thibleroy - 2
rabbitmq-manager no consumers
#136 opened by Mikaelemmmm - 2
- 4
how to deal with confirm mode?
#119 opened by michale-developer - 6
use manual Ack
#126 opened by parsibox - 1
read mutiple message at once
#128 opened by imohsen7 - 1
- 1
error on ack
#133 opened by parsibox - 1
Delete exchange
#120 opened by KrutayaAlpaca - 5
NewPublisher how set to confirm mode
#116 opened by felixhuettner - 5
Not reconnecting in all cases
#99 opened by johanneswuerbach - 0
Integer overflow when compiling for arm 32 arch
#109 opened by rbell13 - 1
Test
#112 opened by sajjadRabiee - 1
Exception (504) Reason: "channel id space exhausted"
#102 opened by anxuanzi - 7
Make channelManager public
#89 opened by gnuletik - 1
Consumer closed while Fetching Messages
#108 opened by sultanfariz - 1
interface for connection struct
#101 opened by aaqaishtyaq - 1
Add support for PublishWithContext
#90 opened by aksu104128 - 1
Missing tests?
#103 opened by gdi3d - 2
publisher resource closure issues
#92 opened by Mikaelemmmm - 3
- 5
Goroutine pool
#88 opened by eshine996 - 1
Error on newConn
#96 opened by amitrahav - 1
How to declare the exchange via the publisher?
#94 opened by kanuku - 3
when server side been maintained, the client will not reconnect success after server side start.
#84 opened by busyfree - 3
- 1
- 1
Truncated messages
#85 opened by aditya-achmad