Function NewConsumer

consumer.go:98–109

NewConsumer Consumer's constructor

(q *Queue, opts ...ConsumerOpt)

// NewConsumer Consumer's constructor
func NewConsumer(q *Queue, opts ...ConsumerOpt) *Consumer {
	c := &Consumer{
		q:          q,
		deliveries: make(chan amqp.Delivery),
		errs:       make(chan error, 100),
		stop:       make(chan struct{}),
	}
	for _, o := range opts {
		o(c)
	}
	return c
}

// Qos on channel
func Qos(count int) ConsumerOpt {