rabbitmq

type Consumer struct {
	Url        string
	Exchange   *Exchange
	Queue      *Queue
	BindingKey []string
	// contains filtered or unexported fields
}

type ConsumerCallback func(*amqp.Delivery) error

type Exchange struct {
	Name         string
	ExchangeType string
	Durable      bool
	AutoDeleted  bool
	Internal     bool
	NoWait       bool
	Arguments    amqp.Table
}

type Publisher struct {
	Url      string
	Exchange *Exchange
	// contains filtered or unexported fields
}

type Queue struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Arguments  amqp.Table
}