bug fixes

src/notification/NotiInterface.ts

@@ -3,8 +3,8 @@
 export interface RabbitMQServiceConfig {
     host: string; // RabbitMQ server host
     port: number; // RabbitMQ server port
-    username: string; // RabbitMQ username
-    password: string; // RabbitMQ password
+    username: "luminosityleds"; // RabbitMQ username
+    password: "Lumi-123"; // RabbitMQ password
     exchange: string; // RabbitMQ exchange
     queue: string; // RabbitMQ queue
     routingKey: string; // RabbitMQ routing key

src/notification/config.ts

@@ -8,8 +8,8 @@ export default {
     rabbitmq: {
       hostname: 'localhost', // RabbitMQ server hostname
       port: 5672, // Default RabbitMQ port
-      username: process.env.RABBITMQ_USERNAME ?? "", // RabbitMQ username
-      password: process.env.RABBITMQ_PASSWORD ?? "", // RabbitMQ password
+      username: process.env.RABBITMQ_USERNAME, // RabbitMQ username
+      password: process.env.RABBITMQ_PASSWORD, // RabbitMQ password
       vhost: '/', // Virtual host (default is '/')
       heartbeat: 10, // Heartbeat interval in seconds
     },

src/notification/connection.ts

@@ -5,10 +5,8 @@ import config from './config'; // Import the RabbitMQ configuration
 // Access the RabbitMQ configuration values
 const rabbitmqConfig = config.rabbitmq;
 
-
 async function connectToRabbitMQ() {
   try {
-
     const connection: amqplib.Connection = await amqplib.connect({
       hostname: rabbitmqConfig.hostname,
       port: rabbitmqConfig.port,
@@ -21,16 +19,17 @@ async function connectToRabbitMQ() {
     // Channel for communication
     const channel: amqplib.Channel = await connection.createChannel();
 
-    // Publish a message to a queue
+    // Declare a durable queue
     const queueName = 'myQueue';
-    await channel.assertQueue(queueName);
-    const message = 'Hello, RabbitMQ!';
-    channel.sendToQueue(queueName, Buffer.from(message));
+    await channel.assertQueue(queueName, { durable: true });
+
+    // Purge the queue (clear existing messages)
+    await channel.purgeQueue(queueName);
 
     // Function to send some messages before consuming the queue
     const sendMessages = (channel: amqplib.Channel) => {
       for (let i = 0; i < 10; i++) {
-        channel.sendToQueue('myQueue', Buffer.from(`message ${i}`));
+        channel.sendToQueue(queueName, Buffer.from(`message ${i}`));
       }
     }
 
@@ -55,4 +54,4 @@ async function connectToRabbitMQ() {
 }
 
 // Call the function to connect to RabbitMQ
-connectToRabbitMQ();
+connectToRabbitMQ();