rabbitmq

type ChannelType string

type Config struct {
	Host     string `yaml:"host"`
	Port     string `yaml:"port"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	AutoACK  bool   `yaml:"auto_ack"`

	QueueName    string      `yaml:"queue"`    // 可为空，代表生成一个no-durable的队列，名字由系统给定
	ExchangeName string      `yaml:"exchange"` // 可为空，若为空则不会使用exchange，而是往queue中直接发送；pubsub和delay必须指定
	Type         ChannelType `yaml:"type"`     // direct/pub_sub/delay

	// aliyun
	Endpoint        string `yaml:"endpoint"`
	AccessKey       string `yaml:"access_key"`
	SecretKey       string `yaml:"secret_key"`
	InstanceID      string `yaml:"instance_id"`
	ConsumerGroupID string `yaml:"consumer_group_id"`
}

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