streadway/amqp Connection/Channel does not reconnect if rabbitmq server restart/down.
To simply developers, here is auto reconnect wrap with detail comments.
- add import
import "github.com/sirius1024/go-amqp-reconnect/rabbitmq" - Replace
amqp.Connection/amqp.Channelwithrabbitmq.Connection/rabbitmq.Channel!
go run example/close/demo.go
go run example/reconnect/demo.go
import "github.com/sirius1024/go-amqp-reconnect/rabbitmq"
rabbitmq.DialCluster([]string{"amqp://usr:pwd@127.0.0.1:5672/vhost","amqp://usr:pwd@127.0.0.1:5673/vhost","amqp://usr:pwd@127.0.0.1:5674/vhost"})