wire queue plugin for AWS.

nitrictech · Feb 5, 2024 · ac2fa8f · ac2fa8f
1 parent fa3221a
commit ac2fa8f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/cloud/aws/cmd/runtime/main.go b/cloud/aws/cmd/runtime/main.go
@@ -24,6 +24,7 @@ import (
 	"github.com/nitrictech/nitric/cloud/aws/runtime/env"
 	lambda_service "github.com/nitrictech/nitric/cloud/aws/runtime/gateway"
 	dynamodb_service "github.com/nitrictech/nitric/cloud/aws/runtime/keyvalue"
+	sqs_service "github.com/nitrictech/nitric/cloud/aws/runtime/queue"
 	"github.com/nitrictech/nitric/cloud/aws/runtime/resource"
 	secrets_manager_secret_service "github.com/nitrictech/nitric/cloud/aws/runtime/secret"
 	s3_service "github.com/nitrictech/nitric/cloud/aws/runtime/storage"
@@ -64,6 +65,7 @@ func main() {
 	membraneOpts.ResourcesPlugin = provider
 	membraneOpts.CreateTracerProvider = newTracerProvider
 	membraneOpts.WebsocketPlugin, _ = websocket.NewAwsApiGatewayWebsocket(provider)
+	membraneOpts.QueuesPlugin, _ = sqs_service.New(provider)
 
 	m, err := membrane.New(membraneOpts)
 	if err != nil {