Skip to content

Automatic Recovery implementation for github.com/streadway/amqp (cloned from isayme / go-amqp-reconnect)

License

Notifications You must be signed in to change notification settings

liboevan/amqpac

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

9 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

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

  1. add import import "github.com/isayme/go-amqp-reconnect/rabbitmq"
  2. Replace amqp.Connection/amqp.Channel with rabbitmq.Connection/rabbitmq.Channel!

Example

Close by developer

go run example/close/demo.go

Auto reconnect

go run example/reconnect/demo.go

About

Automatic Recovery implementation for github.com/streadway/amqp (cloned from isayme / go-amqp-reconnect)

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Go 100.0%