amqp

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

type ExchangeOption struct {
	// 交换机名称
	Name string
	// 交换机类型 如 fanout direct topic
	Kind string
	// Durable 持久化
	Durable bool
	// AutoDelete设置为 true 表示自动删除 慎用 不是自动删除交换机。
	AutoDelete bool
}

type MessageHandle func(ctx context.Context, msg amqp091.Delivery)

type Option func(*option)

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

type QueueBind struct {
	Exchange   string
	RoutingKey string
}

type QueueOption struct {
	Queue      string
	Qos        int
	Durable    bool
	AutoDelete bool
	// 如果配置则自动进行交换机绑定
	BindExchange []QueueBind
}