rabbit

type ConsumeParams struct {
	Queue, ConsumerName                 string
	AutoAck, Exclusive, NoLocal, NoWait bool
	Args                                map[string]interface{}
}

type MessageBroker interface {
	Consume(*ConsumeParams) <-chan amqp.Delivery
	Publish(*PublishParams) error
}

type PublishParams struct {
	Exchange, Routing    string
	Mandatory, Immediate bool
	Body                 []byte
}

type Rabbit struct {
	User, Password, Host, VHost, Port, ConnectionUrl string
	Connection                                       *amqp.Connection
	Chan                                             *amqp.Channel
}