Merge pull request #21 from EYBlockchain/liju.jose/fix-rabbitmq-concu…

…rrency rabbitMQ concurrency issue fixed
EYBlockchain · Mar 4, 2021 · 3c445e1 · 3c445e1
2 parents b2074d0 + 21d7b39
commit 3c445e1
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/src/utils/rabbitmq.mjs b/src/utils/rabbitmq.mjs
@@ -12,7 +12,6 @@ export default {
 
   // publish message to a queue
   async sendMessage(queue, data, options = {}) {
-    await this.channel.assertQueue(queue);
     this.channel.sendToQueue(queue, Buffer.from(JSON.stringify(data)), options);
   },
 

diff --git a/test/queue.mjs b/test/queue.mjs
@@ -25,9 +25,7 @@ const fileToBuffer = filename => {
   });
 };
 
-const generateUuid = () => `${Math.random().toString()}
-  ${Math.random().toString()}
-  ${Math.random().toString()}`;
+const generateUuid = () => `${Math.random()}${Math.random()}${Math.random()}`;
 
 const { expect } = chai;
 let file;