mt

type Binding struct {
	Key       string     `json:"key,omitempty"`
	NoWait    bool       `json:"nowait,omitempty"`
	Arguments amqp.Table `json:"arguments,omitempty"`
}

type Config struct {
	Services map[ServiceName]Service `json:"services"`
}

type Consume struct {
	Tag string `json:"tag,omitempty"`
	// управление сообщением в случае невозможности обработки
	// true - сообщение вновь ставится в очередь
	// false - отбросить сообщение в отстойник, если он настроен. Иначе удалить сообщение
	Requeue   bool       `json:"requeue,omitempty"`
	NoAck     bool       `json:"noack,omitempty"`
	Exclusive bool       `json:"exclusive,omitempty"`
	NoWait    bool       `json:"nowait,omitempty"`
	Arguments amqp.Table `json:"arguments,omitempty"`
}

type Duration time.Duration

type Exchange struct {
	Name       string     `json:"name,omitempty"`
	Type       string     `json:"type,omitempty"`
	Durable    bool       `json:"durable,omitempty"`
	AutoDelete bool       `json:"autodelete,omitempty"`
	Internal   bool       `json:"internal,omitempty"`
	NoWait     bool       `json:"nowait,omitempty"`
	Arguments  amqp.Table `json:"arguments,omitempty"`

	Binding Binding `json:"binding,omitempty"`
	Queue   Queue   `json:"queue,omitempty"`

	ReplyQueue ReplyQueue `json:"replyqueue,omitempty"`
}

type Handler interface {
	Serve(*Request)
}

type HandlerFunc func(*Request, ReplyFunc) error

type Header amqp.Table

type Logger interface {
	Infof(format string, args ...interface{})
	Errorf(format string, args ...interface{})
	Debugf(format string, args ...interface{})
}

type MT struct {
	// contains filtered or unexported fields
}

type MassTransport interface {
	ConnectAndServe() error
	AddHandler(ServiceName, HandlerFunc)
	Call(ServiceName, Request, ReplyFunc) error
	Cast(ServiceName, Request) error
	Shutdown() error
	HealthCheck() bool
}

type Option func(*MT)

type Queue struct {
	Name       string     `json:"name,omitempty"`
	Durable    bool       `json:"durable,omitempty"`
	AutoDelete bool       `json:"autodelete,omitempty"`
	NoWait     bool       `json:"nowait,omitempty"`
	Arguments  amqp.Table `json:"arguments,omitempty"`

	// @see http://www.rabbitmq.com/blog/2012/04/25/rabbitmq-performance-measurements-part-2/
	// Консумер не получит следующие n сообщений, пока не подтвердит предыдущие.
	PrefetchCount int `json:"prefetchCount,omitempty"`

	Consumer Consume `json:"consume,omitempty"`
}

type ReplyFunc func(Response) error

type ReplyQueue struct {
	BindToExchange bool     `json:"bindToExchange,omitempty"`
	Timeout        Duration `json:"timeout,omitempty"`
}

type Request struct {
	Header Header
	Body   []byte
}

type Response struct {
	Body []byte
}

type Service struct {
	Exchange Exchange `json:"exchange"`
}

type ServiceName string