subscriber

type Exchange struct {
	Name          string
	Type          ExchangeType
	IsDurable     bool
	IsAutoDeleted bool
	IsInternal    bool
	NoWait        bool
	Args          map[string]interface{}
	RoutingKey    string
}

type ExchangeType uint8

type Option func(s Subscriber)

type PrefetchQos struct {
	Count    int
	Size     int
	IsGlobal bool
}

type Queue struct {
	Name          string
	Durable       bool
	AutoDelete    bool
	Exclusive     bool
	NoWait        bool
	MaxPriority   uint8
	QueueBindArgs map[string]interface{}
}

type Subscriber interface {
	pubsub.Subscriber
	AddExchange(exchange *Exchange)
	SetQueue(queue *Queue)
	SetName(name string)
	SetPrefetchQos(qos *PrefetchQos)
}