Method queueSubscription

consumer.go:1375–1382

(subscription *brokerSubscription)

}

func (bc *brokerConsumer) queueSubscription(subscription *brokerSubscription) bool {
	select {
	case <-bc.stop:
		return false
	case bc.input <- subscription:
		return true
	}
}