rabbitmq

type ConsumerConfig struct {
	Queue     string
	Consumer  string
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      amqp.Table
}

type Message struct {
	Data        []byte
	ContentType string
}

type ProducerConfig struct {
	Exchange  string
	Key       string
	Mandatory bool
	Immediate bool
}

type RabbitInterface interface {
	Connect() (RabbitInterface, error)
	GetConnect() *rbm_pool
	SimpleQueueDeclare(sq SimpleQueue) (queue amqp.Queue, err error)
	Producer(ctx context.Context, pc *ProducerConfig, msg *Message) error
	Consumer(cc *ConsumerConfig, callback func(msg *amqp.Delivery))
	StartConsumer(cc *ConsumerConfig, callback func(msg *amqp.Delivery))
}

type SimpleQueue struct {
	Name       string     // name
	Durable    bool       // durable
	AutoDelete bool       // delete when unused
	Exclusive  bool       // exclusive
	NoWait     bool       // no-wait
	Arguments  amqp.Table // arguments
}