updating

messaging/messaging.js

@@ -1,20 +1,24 @@
-const amqp = require('amqplib/callback_api');
+const amqp = require('amqplib');
 
-const CONN_URL = 'amqps://hsmwnpfw:[email protected]/hsmwnpfw';
-let ch = null;
-amqp.connect(CONN_URL, function(err, conn){
-    conn.createChannel(function(err, channel){
-        ch = channel;
-    })
-})
+const CONN_URL = process.env.CLOUDAMQP_URL;
 
-const publishToQueue = async (queueName, data) => {
-    ch.sendToQueue(queueName, new Buffer.from(data));
-}
+(async () => {
+    try {
+        const connection = await amqp.connect(CONN_URL);
+        const channel = await connection.createChannel();
 
-process.on('exit', (code) =>{
-    ch.close();
-    console.log('Closing rabbitmq channel');
-});
+        const publishToQueue = (queueName, data) => {
+            const message = Buffer.from(data);
+            channel.sendToQueue(queueName, message);
+        };
 
-module.exports = {publishToQueue}
+        process.on('beforeExit', async (code) => {
+            await channel.close();
+            console.log('Closing RabbitMQ channel');
+        });
+
+        module.exports = { publishToQueue };
+    } catch (error) {
+        console.error('Error:', error);
+    }
+})();