go-rabbitmq
go-rabbitmq copied to clipboard
wagslane
A wrapper of streadway/amqp that provides reconnection logic and sane defaults
In ConsumerOptions, I want to take the bindings to ExchangeOptions and use ExchangeOptions as a slice. This way, a queue can accept multiple bindings from multiple exchanges.:
Hey, we encounter some problems with the reconnection of consumers in our services. It seems that only some of them are being recovered, sometimes even none at all. ``` Initializing...
When trying to publish messages to an exchange that hasn't been created yet multiple times, I get a segmentation violation in amqp091-go. Trying to publish at least twice appears to...
In #145, asynchronous reconnection was changed to synchronous, and we hope to continue supporting asynchronous recovery reconnection. Or can we split the Run() method into two?
When running `consumer.Close` before the `consumer.Run` has finished, `Run` will never return. Prevent this by also getting the `isClosedMux` lock while initialising the handler.
Similar to #66 I am trying to enable confirms using the NotifyPublish handler - attempting to manually keep track of the DeliveryTag being set by incrementing each time I successfully...
While reviewing the code of `v0.14.0`, I realized that the consumer returns `NackRequeue` automatically if a mutex is locked. https://github.com/wagslane/go-rabbitmq/blob/ef6a38050e8e093ad2e0aad5e1f7e37e593548c2/consume.go#L96-L98 However, I'm concerned that when using a [policy with a...
When consuming messages, a stack overflow occurs since v0.14.1 while attempting to reconnect. ``` {"level":"info","date":"2024-06-26T02:19:39.468583548Z","caller":"[email protected]/publish.go:115","msg":"successful publisher recovery from: Exception (320) Reason: \"CONNECTION_FORCED - broker forced connection closure with reason 'shutdown'\"","package":"rabbitmq"}...
This PR adds a basic, but high coverage, integration test to the CI pipeline to validate that we can connect, publish, consume, and close cleanly. The same test setup and...
### rabbitmq server err log  ### go client err log  Will reconnection fail when handshake timeout occurs ？ Thanks for your answer.
