rabbitmq

Author: cristianrgreco

docs/modules/cockroachdb.md

@@ -13,7 +13,7 @@ These examples use the following libraries:
 - [pg](https://www.npmjs.com/package/pg)
 
         npm install pg
-        npm install @types/pg
+        npm install @types/pg --save-dev
 
 Choose an image from the [container registry](https://hub.docker.com/r/cockroachdb/cockroach) and substitute `IMAGE`.
 

docs/modules/mockserver.md

@@ -17,7 +17,7 @@ These examples use the following libraries:
 - [superagent](https://www.npmjs.com/package/superagent)
 
         npm install superagent
-        npm install @types/superagent
+        npm install @types/superagent --save-dev
 
 Choose an image from the [container registry](https://hub.docker.com/r/mockserver/mockserver) and substitute `IMAGE`.
 

docs/modules/mssqlserver.md

@@ -13,7 +13,7 @@ These examples use the following libraries:
 - [mssql](https://www.npmjs.com/package/mssql)
 
         npm install mssql
-        npm install @types/mssql
+        npm install @types/mssql --save-dev
 
 Choose an image from the [container registry](https://mcr.microsoft.com/en-us/artifact/mar/mssql/server) and substitute `IMAGE`.
 

docs/modules/postgresql.md

@@ -13,7 +13,7 @@ These examples use the following libraries:
 - [pg](https://www.npmjs.com/package/pg)
 
         npm install pg
-        npm install @types/pg
+        npm install @types/pg --save-dev
 
 Choose an image from the [container registry](https://hub.docker.com/_/postgres) and substitute `IMAGE`.
 

docs/modules/rabbitmq.md

@@ -1,6 +1,4 @@
-# RabbitMQ Module
-
-[RabbitMQ](https://www.rabbitmq.com/) is a reliable and mature messaging and streaming broker, which is easy to deploy on cloud environments, on-premises, and on your local machine. It is currently used by millions worldwide.
+# RabbitMQ
 
 ## Install
 
@@ -10,14 +8,23 @@ npm install @testcontainers/rabbitmq --save-dev
 
 ## Examples
 
-<!--codeinclude-->
-[Connect:](../../packages/modules/rabbitmq/src/rabbitmq-container.test.ts) inside_block:start
-<!--/codeinclude-->
+These examples use the following libraries:
+
+- [amqplib](https://www.npmjs.com/package/amqplib)
+
+        npm install amqplib
+        npm install @types/amqplib --save-dev
+
+Choose an image from the [container registry](https://hub.docker.com/_/rabbitmq) and substitute `IMAGE`.
+
+### Produce/consume a message
 
 <!--codeinclude-->
-[Set credentials:](../../packages/modules/rabbitmq/src/rabbitmq-container.test.ts) inside_block:credentials
+[](../../packages/modules/rabbitmq/src/rabbitmq-container.test.ts) inside_block:pubsub
 <!--/codeinclude-->
 
+### With credentials
+
 <!--codeinclude-->
-[Publish and subscribe:](../../packages/modules/rabbitmq/src/rabbitmq-container.test.ts) inside_block:pubsub
+[](../../packages/modules/rabbitmq/src/rabbitmq-container.test.ts) inside_block:credentials
 <!--/codeinclude-->

packages/modules/rabbitmq/src/rabbitmq-container.test.ts

@@ -7,19 +7,19 @@ const IMAGE = getImage(__dirname);
 describe("RabbitMQContainer", { timeout: 240_000 }, () => {
   // start {
   it("should start, connect and close", async () => {
-    await using rabbitMQContainer = await new RabbitMQContainer(IMAGE).start();
+    await using container = await new RabbitMQContainer(IMAGE).start();
 
-    const connection = await amqp.connect(rabbitMQContainer.getAmqpUrl());
+    const connection = await amqp.connect(container.getAmqpUrl());
     await connection.close();
   });
   // }
 
-  // credentials {
   it("different username and password", async () => {
+    // credentials {
     const USER = "user";
     const PASSWORD = "password";
 
-    await using rabbitMQContainer = await new RabbitMQContainer(IMAGE)
+    await using container = await new RabbitMQContainer(IMAGE)
       .withEnvironment({
         RABBITMQ_DEFAULT_USER: USER,
         RABBITMQ_DEFAULT_PASS: PASSWORD,
@@ -29,21 +29,21 @@ describe("RabbitMQContainer", { timeout: 240_000 }, () => {
     const connection = await amqp.connect({
       username: USER,
       password: PASSWORD,
-      port: rabbitMQContainer.getMappedPort(5672),
+      port: container.getMappedPort(5672),
     });
+    // }
 
     await connection.close();
   });
-  // }
 
-  // pubsub {
   it("test publish and subscribe", async () => {
+    // pubsub {
     const QUEUE = "test";
     const PAYLOAD = "Hello World";
 
-    await using rabbitMQContainer = await new RabbitMQContainer(IMAGE).start();
-    const connection = await amqp.connect(rabbitMQContainer.getAmqpUrl());
+    await using container = await new RabbitMQContainer(IMAGE).start();
 
+    const connection = await amqp.connect(container.getAmqpUrl());
     const channel = await connection.createChannel();
     await channel.assertQueue(QUEUE);
 
@@ -58,6 +58,6 @@ describe("RabbitMQContainer", { timeout: 240_000 }, () => {
 
     await channel.close();
     await connection.close();
+    // }
   }, 20_000);
-  // }
 });