func receiveMessages()

in Sample-Code-Snippets/Go/azure-service-bus-emulator-console-sample/main.go [47:66]

• 17 lines of code
• 4 McCabe index (conditional complexity)

func receiveMessages(client *azservicebus.Client, queueName string) {
	receiver, err := client.NewReceiverForQueue(queueName, nil)
	if err != nil {
		log.Fatalf("failed to create receiver: %s", err)
	}
	defer receiver.Close(context.Background())

	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()

	messages, err := receiver.ReceiveMessages(ctx, 1, nil)
	if err != nil {
		log.Fatalf("failed to receive messages: %s", err)
	}

	for _, msg := range messages {
		fmt.Println("Received message:", string(msg.Body))
		receiver.CompleteMessage(ctx, msg, nil)
	}
}