Local SQS Queue Setup

main.go

package main

import (
	"context"
	"log"

	"github.com/aws/aws-sdk-go-v2/aws"
	"github.com/aws/aws-sdk-go-v2/config"
	"github.com/aws/aws-sdk-go-v2/service/sqs"
)

type localResolver struct{}

func (l localResolver) ResolveEndpoint(service, region string, options ...interface{}) (aws.Endpoint, error) {
	return aws.Endpoint{
		URL:           "http://localhost:9324",
		SigningRegion: "eu-west-1",
	}, nil
}

func main() {
	cfg, err := config.LoadDefaultConfig(context.Background())
	if err != nil {
		log.Fatal(err)
	}

	cfg.EndpointResolverWithOptions = localResolver{}

	sqsClient := sqs.NewFromConfig(cfg)

	res, err := sqsClient.ListQueues(context.Background(), &sqs.ListQueuesInput{
		MaxResults:      aws.Int32(10),
		NextToken:       nil,
		QueueNamePrefix: nil,
	})

	if err != nil {
		log.Printf("error while listing the queues")
	}

	for _, queue := range res.QueueUrls {
		log.Println(queue)
	}
}

Code for the blog post of Local SQS Setup With Golang