rabbit_ch_pool

type ChannelPool struct {
	// contains filtered or unexported fields
}

type Options struct {
	Addr            string
	PoolSize        int
	ExchangeDeclare bool
	ExchangeName    string
	ExchangeType    string
	PoolTimeout     time.Duration
	ReconnectDelay  time.Duration
}

type Pooler interface {
	Get() (*amqp.Channel, error)
	Put(ch *amqp.Channel) error
}

type Rabbit struct {
	// contains filtered or unexported fields
}