rabbitmq

type AMQPEnv struct {
	User            string `env:"RABBIT_USER" envDefault:"guest"`
	Password        string `env:"RABBIT_PASSWORD" envDefault:"guest"`
	URL             string `env:"RABBIT_URL" envDefault:"localhost"`
	Vhost           string `env:"RABBIT_VHOST" envDefault:""`
	CredentialsFile string `env:"RABBIT_CREDENTIALS_FILE" envDefault:""`
	Protocol        string `env:"RABBIT_PROTOCOL" envDefault:"amqp"`
}

type Channel struct {
	*amqp.Channel
	// contains filtered or unexported fields
}

type Config interface {
	GetAMQPEnv() *AMQPEnv
}

type Connection struct {
	*amqp.Connection
}

type RabbitClient struct {
	*Connection

	AppName       string
	PublisherMode bool
	// contains filtered or unexported fields
}