mq

type Binding struct {
	QueueName    string
	ExchangeName string
	BindingKey   string
}

type RabbitClient struct {
	ConnectionString string

	AutoACK            bool
	QueueNames         []string
	ConsumeQueues      []string
	ExchangeNames      []string
	DefaultContentType string
	Bindings           []Binding
	PrefetchCount      int
	ConsumeHandler     func(queueName string, d amqp.Delivery) error
	// contains filtered or unexported fields
}