go-amqp-reconnect
go-amqp-reconnect copied to clipboard
Published
20 hours ago •
isayme
isayme
auto reconnecting example for github.com/streadway/amqp Connection & Channel
streadway/amqp Conneciton/Channel auto reconnect wrap
streadway/amqp Connection/Channel does not reconnect if rabbitmq server restart/down.
To simply developers, here is auto reconnect wrap with detail comments.
How to change existing code
- add import
import "github.com/isayme/go-amqp-reconnect/rabbitmq" - Replace
amqp.Connection/amqp.Channelwithrabbitmq.Connection/rabbitmq.Channel!
Example
Close by developer
go run example/close/demo.go
Auto reconnect
go run example/reconnect/demo.go
isayme