code: func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) {
  	if b.retryFunc == nil {
  		b.retryFunc = retry.Closure()
  	}
  
  	b.stopChan = make(chan int)
  	b.retryStopChan = make(chan int)
  }
docs: // StartConsuming is a common part of StartConsuming method