rmqconsumer

type Config struct {
	Uri          string
	Exchange     string
	ExchangeType string
	Queue        string
	Tag          string
	RoutingKey   string
}

type Handle func(body []byte)

type Option func(*Options)

type Options struct {
	Handle Handle
	Config *Config
}

type RmqConsumer interface {
	Init(...Option) error
	Options() Options
	Shutdown() error
}