added back rabbitmq

fixed error in accessing kafka bus api

Author: Vikas Agarwal

src/routes/projects/create.js

@@ -149,10 +149,10 @@ module.exports = [
             // add an empty attachments array
             newProject.attachments = [];
             req.log.debug('Sending event to RabbitMQ bus for project %d', newProject.id);
-            // req.app.services.pubsub.publish(EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED,
-            //   newProject,
-            //   { correlationId: req.id },
-            // );
+            req.app.services.pubsub.publish(EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED,
+              newProject,
+              { correlationId: req.id },
+            );
             req.log.debug('Sending event to Kafka bus for project %d', newProject.id);
             // emit event
             req.app.emit(EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED, { req, project: newProject });

src/services/busApi.js

@@ -42,7 +42,7 @@ function getClient() {
 function createEvent(type, message, logger) {
   const body = JSON.stringify(message);
   logger.debug(`Sending message: ${JSON.stringify(message)}`);
-  return getClient().post('/v5/bus/events', {
+  return getClient().post('/bus/events', {
     type,
     message: body,
   })

src/services/index.js

@@ -20,20 +20,20 @@ module.exports = (fapp, logger) => {
   } else {
     logger.info('initializing RabbitMQ service');
     // RabbitMQ Initialization
-    // app.services.pubsub = new RabbitMQService(logger);
+    app.services.pubsub = new RabbitMQService(logger);
 
-    // // initialize RabbitMQ
-    // app.services.pubsub.init(
-    //   config.get('rabbitmqURL'),
-    //   config.get('pubsubExchangeName'),
-    //   config.get('pubsubQueueName'),
-    // )
-    // .then(() => {
-    //   logger.info('RabbitMQ service initialized');
-    // })
-    // .catch((err) => {
-    //   logger.error('Error initializing services', err);
-    //   // gracefulShutdown()
-    // });
+    // initialize RabbitMQ
+    app.services.pubsub.init(
+      config.get('rabbitmqURL'),
+      config.get('pubsubExchangeName'),
+      config.get('pubsubQueueName'),
+    )
+    .then(() => {
+      logger.info('RabbitMQ service initialized');
+    })
+    .catch((err) => {
+      logger.error('Error initializing services', err);
+      // gracefulShutdown()
+    });
   }
 };