mq

type ApplyTopology func(exchange, queue, routingKey string, ch *amqp.Channel) error

type Config struct {
	Host     string `json:"host" mapstructure:"host"`
	Port     int64  `json:"port" mapstructure:"port"`
	Username string `json:"username" mapstructure:"username"`
	Password string `json:"password" mapstructure:"password"`
	IsUse    bool   `json:"isUse" mapstructure:"isUse"`
}

type ConsumeHandler func(d amqp.Delivery) error

type Wrapper struct {
	Addr   string
	Config amqp.Config
	// contains filtered or unexported fields
}