Created files for RabbitMQ service

.devcontainer/connection.js

@@ -0,0 +1,89 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+var __generator = (this && this.__generator) || function (thisArg, body) {
+    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
+    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
+    function verb(n) { return function (v) { return step([n, v]); }; }
+    function step(op) {
+        if (f) throw new TypeError("Generator is already executing.");
+        while (g && (g = 0, op[0] && (_ = 0)), _) try {
+            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
+            if (y = 0, t) op = [op[0] & 2, t.value];
+            switch (op[0]) {
+                case 0: case 1: t = op; break;
+                case 4: _.label++; return { value: op[1], done: false };
+                case 5: _.label++; y = op[1]; op = [0]; continue;
+                case 7: op = _.ops.pop(); _.trys.pop(); continue;
+                default:
+                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
+                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
+                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
+                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
+                    if (t[2]) _.ops.pop();
+                    _.trys.pop(); continue;
+            }
+            op = body.call(thisArg, _);
+        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
+        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
+    }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+var amqplib = require("amqplib");
+function connectToRabbitMQ() {
+    return __awaiter(this, void 0, void 0, function () {
+        var connection, channel_1, queueName, message, error_1;
+        return __generator(this, function (_a) {
+            switch (_a.label) {
+                case 0:
+                    _a.trys.push([0, 7, , 8]);
+                    return [4 /*yield*/, amqplib.connect('amqp://luminosityleds:Lumi-123@localhost:5672')];
+                case 1:
+                    connection = _a.sent();
+                    return [4 /*yield*/, connection.createChannel()];
+                case 2:
+                    channel_1 = _a.sent();
+                    queueName = 'myQueue';
+                    return [4 /*yield*/, channel_1.assertQueue(queueName)];
+                case 3:
+                    _a.sent();
+                    message = 'Hello, RabbitMQ!';
+                    channel_1.sendToQueue(queueName, Buffer.from(message));
+                    // Consume messages from a queue
+                    return [4 /*yield*/, channel_1.consume(queueName, function (msg) {
+                            if (msg !== null) {
+                                console.log('Received message:', msg.content.toString());
+                                // Acknowledge the message
+                                channel_1.ack(msg);
+                            }
+                        })];
+                case 4:
+                    // Consume messages from a queue
+                    _a.sent();
+                    // Close the channel and the connection when done
+                    return [4 /*yield*/, channel_1.close()];
+                case 5:
+                    // Close the channel and the connection when done
+                    _a.sent();
+                    return [4 /*yield*/, connection.close()];
+                case 6:
+                    _a.sent();
+                    return [3 /*break*/, 8];
+                case 7:
+                    error_1 = _a.sent();
+                    console.error('Error connecting to RabbitMQ:', error_1);
+                    return [3 /*break*/, 8];
+                case 8: return [2 /*return*/];
+            }
+        });
+    });
+}
+// Call the function to connect to RabbitMQ
+connectToRabbitMQ();

.devcontainer/connection.ts

@@ -0,0 +1,51 @@
+import * as amqplib from 'amqplib';
+
+// Define type references for Connection and Channel
+type Connection = amqplib.Connection;
+type Channel = amqplib.Channel;
+
+async function connectToRabbitMQ() 
+{
+  try 
+  {
+    // Replace 'username' and 'password' with your RabbitMQ credentials
+    const connection: Connection = await amqplib.connect
+    (
+        'amqp://luminosityleds:Lumi-123@localhost:5672'
+    );
+
+    // Channel for communication
+    const channel: Channel = await connection.createChannel();
+
+    // We can use the 'channel' to perform various RabbitMQ operations
+
+    // Publish a message to a queue
+    const queueName = 'myQueue';
+    await channel.assertQueue(queueName);
+    const message = 'Hello, RabbitMQ!';
+    channel.sendToQueue(queueName, Buffer.from(message));
+
+    // Consume messages from a queue
+    await channel.consume(queueName, (msg) => 
+    {
+      if (msg !== null) {
+        console.log('Received message:', msg.content.toString());
+        // Acknowledge the message
+        channel.ack(msg);
+      }
+    });
+
+    // Close the channel and the connection when done
+    await channel.close();
+    await connection.close();
+  } 
+
+  catch (error) // Incase of an error
+  {
+    console.error('Error connecting to RabbitMQ:', error);
+  }
+
+}
+
+// Call the function to connect to RabbitMQ
+connectToRabbitMQ();

.devcontainer/devcontainer.json

@@ -5,10 +5,12 @@
 	// Or use a Dockerfile or Docker Compose file. More info: https://containers.dev/guide/dockerfile
 	// Uses Debian 11 for Dev environment
 	// https://github.com/microsoft/vscode-dev-containers/tree/main/containers/debian#using-this-definition
-	"image": "mcr.microsoft.com/devcontainers/base:bullseye",
+	"image": "rabbitmq",
 
-	"features": {
-		"ghcr.io/devcontainers/features/docker-in-docker:2": {
+	"features": 
+	{
+		"ghcr.io/devcontainers/features/docker-in-docker:2": 
+		{
 			"version": "latest",
 			"enableNonRootDocker": "true",
 			"moby": "true"
@@ -25,9 +27,12 @@
 	// "postCreateCommand": "docker --version",
 
 	// Configure tool-specific properties.
-	"customizations": {
-		"vscode": {
-		  "extensions": [
+	"customizations": 
+	{
+		"vscode": 
+		{
+		  "extensions": 
+		  [
 			"eamodio.gitlens",
 			"esbenp.prettier-vscode",
 			"TabNine.tabnine-vscode",

.devcontainer/docker-compose.yaml

@@ -0,0 +1,18 @@
+version: "3.7"
+services:
+  rabbitmq:
+    image: rabbitmq:3.9.13-management-alpine
+    container_name: 'rabbitmq'
+    restart: always
+    environment:
+      - "RABBITMQ_DEFAULT_PASS=Lumi-123"
+      - "RABBITMQ_DEFAULT_USER=luminosityleds"
+    ports:
+      - 15672:15672
+      - 5672:5672
+    networks:
+      - rabbitmq_go_net
+
+networks:
+  rabbitmq_go_net:
+    driver: bridge