rabbitmq

type ConfigInfo struct {
	Addr     string
	UserName string
	Password string
	Port     string
}

type MessageHandler struct {
	QueueName  string
	Exchange   string
	Key        string
	Handler    func(exchange string, body []byte)
	AutoDelete bool
	RetryCount int
}

type RabbitMQ struct {
	Url        string
	Conn       *amqp.Connection
	Handlers   []*MessageHandler
	RetryCount int
}