mqueue

type Config struct {
	Name   string
	Url    string
	Driver string
}

type Queue interface {
	Send(body []byte) error
	Delay(body []byte, expire string) error
	Receive(callback func(body []byte)) error
	SetLogger(l queue.Logger)
	EnableLog(e bool)
}