Update SQS adapter usage examples

Author: domwebber

packages/queue/README.md

@@ -108,7 +108,11 @@ const isProduction = process.env.NODE_ENV === "production";
 const outgoingQueue = new MQueue.Outgoing(
   isProduction
     ? await AmqplibOutgoingQueue.connect("amqp://rabbitmq:5271", "queue-name")
-    : await SQSOutgoingQueue.connect("amqp://rabbitmq:5271", "queue-name"),
+    : await SQSOutgoingQueue.connect("/queue1", {
+        credentials: { accessKeyId: "x", secretAccessKey: "x" },
+        region: "elasticmq", // or applicable AWS region for SQS
+        endpoint: "http://elasticmq:9324",
+      }),
 );
 
 outgoingQueue.sendMessage({
@@ -123,7 +127,11 @@ outgoingQueue.sendMessage({
 const incomingQueue = new MQueue.Incoming(
   isProduction
     ? await AmqplibIncomingQueue.connect("amqp://rabbitmq:5271", "queue-name")
-    : await SQSIncomingQueue.connect("amqp://rabbitmq:5271", "queue-name"),
+    : await SQSIncomingQueue.connect("/queue1", {
+        credentials: { accessKeyId: "x", secretAccessKey: "x" },
+        region: "elasticmq", // or applicable AWS region for SQS
+        endpoint: "http://elasticmq:9324",
+      }),
 );
 ```
 

packages/sqs/README.md

@@ -16,7 +16,11 @@ import MQueue from "@mqueue/queue"; // or require("@mqueue/queue")
 import { SQSQueue } from "@mqueue/fastq"; // or require("@mqueue/fastq");
 
 const outgoingQueue = new MQueue.Outgoing(
-  await SQSQueue.Outgoing.connect("amqp://rabbitmq:5271", "queue-name"),
+  await SQSQueue.Outgoing.connect("/queue1", {
+    credentials: { accessKeyId: "x", secretAccessKey: "x" },
+    region: "elasticmq", // or applicable AWS region for SQS
+    endpoint: "http://elasticmq:9324",
+  }),
 );
 
 outgoingQueue.sendMessage({
@@ -29,7 +33,11 @@ outgoingQueue.sendMessage({
 // ...
 
 const incomingQueue = new MQueue.Incoming(
-  await SQSQueue.Incoming.connect("amqp://rabbitmq:5271", "queue-name"),
+  await SQSQueue.Incoming.connect("/queue1", {
+    credentials: { accessKeyId: "x", secretAccessKey: "x" },
+    region: "elasticmq", // or applicable AWS region for SQS
+    endpoint: "http://elasticmq:9324",
+  }),
 );
 
 // Start listening to the queue

packages/sqs/tests/ElasticMQContainer.ts

@@ -77,6 +77,6 @@ export class StartedElasticMQContainer extends AbstractStartedContainer {
   }
 
   public getSQSUrl(): string {
-    return `http://${this.useAlias ? "activemq" : this.getHost()}:${this.getRestPort()}`;
+    return `http://${this.useAlias ? "elasticmq" : this.getHost()}:${this.getRestPort()}`;
   }
 }