go-rabbitmq
go-rabbitmq copied to clipboard
wagslane
A wrapper of streadway/amqp that provides reconnection logic and sane defaults
Hello, Sometimes I receive truncated message. `{"position":{"latitude":0.0,"longitude":0.0,"altitude":0.0},"device":{"id":1,"name":"1111","phone":nu` It supposed to be like this: `{"position":{"latitude":0.0,"longitude":0.0,"altitude":0.0},"device":{"id":1,"name":"1111","phone":null}}` And sometimes I receive message with extra string too. `{"position":{"latitude":0.0,"longitude":0.0,"altitude":0.0},"device":{"id":1,"name":"1111","phone":null}}1111","phone":null}}` How to solve this issue?
how to handle when server side been maintained, the client will not reconnect success after server side start. ``` 2022/08/09 03:07:15 gorabbit ERROR: attempting to reconnect to amqp server after...
memory leak
  My English is not very good, please understand.As the concurrency of my project increases, the memory also increases. After investigation, it was found that the reason was due...
Hello. Thank you for your work. I tried to declare a queue with "x-dead-letter-exchange" argument to my main exchange. The problem is that I need to pass Handler for consumer...
Currently, when connecting to RabbitMQ, the client relies on a single host. ```golang var singleHost string = "amqp://guest:guest@localhost" conn, err := rabbitmq.NewConn( singleHost, rabbitmq.WithConnectionOptionsLogging, ) ``` In scenarios where high...
This change separates the creation and running of the consumer to allow the caller to handle errors when it's not possible to retry. A library should never call log.Fatal or...
Hello bro, we need to wait goroutine to completed, then close the consumer, ` go handlerGoroutine(consumer, msgs, options, handler) ` I Want a consumer gracefull-shutdown demo. Thanks a lot.
I'd like to propose adding a `WaitForHandlers` method to the consumer which waits for any running handlers to complete processing their current messages. This is because `Close` doesn't wait for...
