go-rabbitmq

go-rabbitmq copied to clipboard

Hello, probably here error handling missed. It looks like even if it needs to be ignored here it would be good to add some logging in case of error. It...

ldmi3i

Split #80 into two parts. This part contains: - declaration of queues, exchanges and bindings is also possible if the Publisher is used (#43 ) - updated examples

h44z

Split #80 into two parts. This part contains: - queue, exchange and binding declaration is now simplified and much clearer to use - updated examples

h44z

Each consumer/ producer has it's own connection?

1

Hello, from my understanding of the code, each consumer/ publisher will have its own connection, which contradicts the recommendation of 1 connection per application. In theory, every consumer/ producer should...

Nikola-Milovic

Why is Exchange configuration driven by Consumers instead of Publishers

7

This library seems to have Consumers drive the configuration of the Exchanges rather than the Publishers. For example, Consumers determine if an exchange should auto delete, be durable, or the...

ghost

WithPublisherOptionsReconnectInterval is a ConsumerOption. How to use it?

1

Try to get this option working as currently the publisher got disconnected but not retrying... Error publishing message: Exception (504) Reason: \"channel/connection is not open\ `err := publisher.Publish( []byte(data), []string{keyRouter},...

willthrom

Is there a way to notify my app is rmq connection was closed? This's super important in different cases like change app status to unhealthy Thanks

kotyara85

Will Goroutine pool be added？

eshine996

Sorry I'm new to golang, I just created 1 consumer to consume multiple queues. But when the connection dropped, and the reconnect mechanism started, it successfully reconnect but only to...

FR19

How to resend a message when it fails to send

2

How to resend a message when it fails to send

yeyudekuangxiang