rabbit

type Binding struct {
	Exchange string `yaml:"exchange"`
	Key      string `yaml:"key"`
	Nowait   bool   `yaml:"nowait"`
}

type Client interface {
	CreateScheme(s *Options) error
	SendMessage(ex, key string, data []byte, headers map[string]interface{}) error
	ProcessQueue(name string, f func(map[string]interface{}, []byte) error) error
}

type Exchange struct {
	Durable    bool      `yaml:"durable"`
	AutoDelete bool      `yaml:"auto-delete"`
	Internal   bool      `yaml:"internal"`
	Nowait     bool      `yaml:"nowait"`
	Type       string    `yaml:"type"`
	Bindings   []Binding `yaml:"bindings"`
	Args       map[string]interface{}
}

type Options struct {
	Addresses   string               `yaml:"addresses"`
	Username    string               `yaml:"username"`
	Password    string               `yaml:"password"`
	VirtualHost string               `yaml:"virtual-host"`
	Exchanges   map[string]Exchange  `yaml:"exchanges"`
	Queues      map[string]QueueSpec `yaml:"queues"`
}

type QueueSpec struct {
	Durable    bool      `yaml:"durable"`
	AutoDelete bool      `yaml:"auto-delete"`
	Nowait     bool      `yaml:"nowait"`
	Exclusive  bool      `yaml:"exclusive"`
	Bindings   []Binding `yaml:"bindings"`
}