Use ElasticMQ with AWS SDK v2

elasticmq.go

ctx := context.TODO()
queueName := "something"
endpointURL := "http://localhost:9324"
messageBody := "test"

// Create a custom endpoint resolver for ElasticMQ
elasticmqResolver := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
	if service == sqs.ServiceID {
		return aws.Endpoint{URL: endpointURL}, nil
	}
	return aws.Endpoint{}, &aws.EndpointNotFoundError{}
})

// Create AWS SDK configuration using the custom endpoint resolver
sdkConfig, err := sqsconfig.LoadDefaultConfig(context.TODO(), sqsconfig.WithEndpointResolverWithOptions(elasticmqResolver))
if err != nil {
	panic("aws sdk v2 configuration error, " + err.Error())
}

// Create an ElasticMQ client using the AWS SDK
client := sqs.NewFromConfig(sdkConfig)
queueURL := endpointURL + "/queue/" + queueName

// Prepare the message
input := sqs.SendMessageInput{
	MessageBody:  &messageBody,
	QueueUrl:     aws.String(queueURL),
	DelaySeconds: 1,
}

// Send the message
output, err := client.SendMessage(ctx, &input)
if err != nil {
	panic("could not send message to queue, " + err.Error())
}
fmt.Printf("message ID: %s", *output.MessageId)