rabbitmq

type Option func(*Options)

type Options struct {
	Logger logger.Logger `ignored:"true" json:"-"`

	Host        string `default:"0.0.0.0" envconfig:"HOST"`
	Port        int    `default:"5672" envconfig:"PORT"`
	Username    string `default:"guest" envconfig:"USERNAME"`
	Password    string `default:"guest" envconfig:"PASSWORD"`
	VirtualHost string `default:"/" envconfig:"VHOST"`
	ConnTimeout int    `default:"10" envconfig:"CONN_TIMEOUT"`

	InstName    string `default:"unknown" envconfig:"INST_NAME"`
	InstVersion string `default:"unknown" envconfig:"INST_VERSION"`
}

type RabbitMQ interface {
	Connect()
	Disconnect() error

	OnMessage(message.OnMessageHandler, ...consumer.Option)
}