code: func (b *Broker) continueReceivingMessages(qURL *string, deliveries chan *awssqs.ReceiveMessageOutput) (bool, error) {
  	select {
  	// A way to stop this goroutine from b.StopConsuming
  	case <-b.stopReceivingChan:
  		return false, nil
  	default:
  		output, err := b.receiveMessage(qURL)
  		if err != nil {
  			return true, err
  		}
  		if len(output.Messages) == 0 {
  			return true, nil
  		}
  		go func() { deliveries <- output }()
  	}
  	return true, nil
  }
docs: // continueReceivingMessages is a method returns a continue signal