amqp_pool

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

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

type ChannelService interface {
	Publish() error
}

type ConnPoolConfig struct {
	ConnNum uint16
	Url     string
}

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

type ConnectionConfig struct {
	ChanNum uint16
	Url     string
}

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

type ExchangeDeclareConfig struct {
	Name       string
	Kind       string
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       amqp.Table
}

type PublishData struct {
	Exchange  string
	Key       string
	Mandatory bool // 如果没有队列 true 返回给生产者 false 会丢掉
	Immediate bool // 如果没有消费者 true 返回给生产者，false 丢入队列
	Msg       amqp.Publishing
}

type QueueDeclareConfig struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table
}