rabbitmq

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

type Message struct {
	Data        []byte
	ContentType string
}

type RabbitInterface interface {
	Publish(ctx context.Context, queue_name string, msg *Message) error
	Consumer(queue_name string, callback func(msg *amqp.Delivery))
	Connect() error
	Start(queue_name string, callback func(msg *amqp.Delivery))
}