code: func (b *Broker) StopConsuming() {
  	b.Broker.StopConsuming()
  
  	b.stopReceiving()
  
  	// Waiting for any tasks being processed to finish
  	b.processingWG.Wait()
  
  	// Waiting for the receiving goroutine to have stopped
  	b.receivingWG.Wait()
  }
docs: // StopConsuming quits the loop