amqp

type Channel interface {
	Connect(conn *amqp.Connection) error
}

type Config struct {
	User           string
	Password       string
	Host           string
	ConnectTimeout time.Duration
}

type Connection interface {
	Start() error
	Stop() error
	AddChannel(channel Channel)
}

type Logger interface {
	Info(...interface{})
	Error(error, ...interface{})
}