subscriber

type Exchange struct {
	// Name is the exchange name.
	Name string

	// Type is the exchange type. See ExchangeType for details.
	Type ExchangeType

	// IsDurable defines if is a durable queue.
	IsDurable bool

	// IsAutoDeleted defines if exchange is auto deleted.
	IsAutoDeleted bool

	// IsInternal defines if is a internal exchange.
	IsInternal bool

	// NoWait defines if is a noWait queue.
	NoWait bool

	// Args exchange creation args.
	Args map[string]interface{}

	// RoutingKey is the routingKey used to bind exchange to consumer queue (for topic exchanges).
	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
	RoutingKey    string
	QueueBindArgs map[string]interface{}
}

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