New
v1.53.0
Release v1.53.0
π Features
πΉ Amazon SQS PubSub Support
GoFr now supports Amazon SQS as a messaging backend, enabling seamless integration with AWS Simple Queue Service for building resilient, distributed microservices.
- Supports both Publishing and Subscribing to SQS standard queues
- Configurable Behavior:
- Support for custom message attributes
- Configurable visibility timeouts and wait times
- Support for standard queues
Usage Example
To use Amazon SQS, import the driver and add it to your application:
import (
"gofr.dev/pkg/gofr"
"gofr.dev/pkg/gofr/datasource/pubsub/sqs"
)
func main() {
app := gofr.New()
app.AddPubSub(sqs.New(&sqs.Config{
Region: "us-east-1",
AccessKeyID: "your-access-key-id", // optional if using IAM roles
SecretAccessKey: "your-secret-access-key", // optional if using IAM roles
// Endpoint: "http://localhost:4566", // optional: for LocalStack
}))
app.Subscribe("my-queue", func(ctx *gofr.Context) error {
// Process message
return nil
})
app.Run()
}