code: func (b *Broker) StopConsuming() {
  	// Do not retry from now on
  	b.retry = false
  	// Stop the retry closure earlier
  	select {
  	case b.retryStopChan <- 1:
  		log.WARNING.Print("Stopping retry closure.")
  	default:
  	}
  	// Notifying the stop channel stops consuming of messages
  	select {
  	case b.stopChan <- 1:
  		log.WARNING.Print("Stop channel")
  	default:
  	}
  }
docs: // StopConsuming is a common part of StopConsuming