broker

type Dialer = func(endpoint string) (*amqp.Connection, error)

type FairPool struct {
	Dialer         Dialer
	Endpoints      []url.URL
	RedialInterval time.Duration
	AcquireTimeout time.Duration

	OnBrokerOpen  func(url.URL)
	OnBrokerClose func(url.URL)
	OnBrokerError func(error)
	// contains filtered or unexported fields
}

type Pool interface {
	Launch()
	Shutdown()
	Acquire() *amqp.Connection
	Release(*amqp.Connection)
}