rabbitmq

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	ServiceName string
	Host        string
	Port        int
	Virtual     string
	User        string
	Pass        string
}

type ConsumeParams struct {
	Context     context.Context
	Queue       string
	AutoAck     bool
	Exclusive   bool
	NoLocal     bool
	NoWait      bool
	Args        amqp.Table
	MultipleAck bool
	Consumer    queue.Consumer
}

type ProduceMessage struct {
	Exchange  string // exchange
	Key       string // routing key
	Mandatory bool   // set true, when no queue match Basic.Return
	Immediate bool   // set false, not dependent consumers
	// amqp.Publishing{
	// 	DeliveryMode: amqp.Persistent,
	// 	ContentType:  "text/plain",
	// 	Body:         m,
	// })
	Message     amqp.Publishing
	OpenConfirm bool
}