Method getMqBrokersPerRegion

aws/endpoints.go:546–610

(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint)

}

func (m *EndpointsModule) getMqBrokersPerRegion(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint) {
	defer func() {
		m.CommandCounter.DecrExecuting()
		m.CommandCounter.IncrComplete()
		wg.Done()

	}()
	semaphore <- struct{}{}
	defer func() {
		<-semaphore
	}()
	// m.CommandCounter.IncrTotal()
	m.CommandCounter.DecrPending()
	m.CommandCounter.IncrExecuting()

	BrokerSummaries, err := sdk.CachedMQListBrokers(m.MQClient, aws.ToString(m.Caller.Account), r)
	if err != nil {
		m.modLog.Error(err.Error())
		m.CommandCounter.IncrError()
		return
	}

	var public string
	for _, broker := range BrokerSummaries {
		name := aws.ToString(broker.BrokerName)
		id := broker.BrokerId

		BrokerDetails, err := m.MQClient.DescribeBroker(
			context.TODO(),
			&(mq.DescribeBrokerInput{
				BrokerId: id,
			}),
			func(o *mq.Options) {
				o.Region = r
			},
		)
		if err != nil {
			if errors.As(err, &oe) {
				m.Errors = append(m.Errors, fmt.Sprintf(" Error: Region: %s, Service: %s, Operation: %s", r, oe.Service(), oe.Operation()))
			}
			m.modLog.Error(err.Error())
			m.CommandCounter.IncrError()
			continue
		}
		if aws.ToBool(BrokerDetails.PubliclyAccessible) {
			public = "True"
		} else {
			public = "False"
		}

		endpoint := aws.ToString(BrokerDetails.BrokerInstances[0].ConsoleURL)

		dataReceiver <- Endpoint{
			AWSService: "Amazon MQ",
			Region:     r,
			Name:       name,
			Endpoint:   endpoint,
			Port:       443,