easy_amqp

var (
	DefaultQueueDurable       = true
	DefaultQueueAutoDelete    = false
	DefaultQueueNoWait        = false
	DefaultQueueExclusive     = false
	DefaultExchangeDurable    = true
	DefaultExchangeAutoDelete = false
	DefaultExchangeNoWait     = false
	DefaultExchangeInternal   = false
	DefaultRouteKey           = ""
	DefaultBindNoWait         = false
)

var (
	QueueDeclared    = make(map[string]Queue)
	ExchangeDeclared = make(map[string]Exchange)
)

var (
	ErrorClosed         = errors.New("publisher is closed")
	ErrorAmqpConnection = errors.New("error amqp connection")
	ErrorNoChannel      = errors.New("not channel gets")
	ErrorBuildChannel   = errors.New("can't build channel")
)

var (
	ErrorConnection          = errors.New("error connection of amqp")
	ErrorChanRecvFail        = errors.New("channel recv fail")
	ErrorEmptySubscribeQueue = errors.New("subscribe queues empty")
)

var (
	ErrorInvalidContentType = errors.New("invalid content type")
)