code: func (eagerBroker *Broker) StartConsuming(consumerTag string, concurrency int, p iface.TaskProcessor) (bool, error) {
  	return true, nil
  }
docs: // StartConsuming enters a loop and waits for incoming messages