Skip to content

Commit 3c445e1

Browse files
author
Duncan Westland
authored
Merge pull request #21 from EYBlockchain/liju.jose/fix-rabbitmq-concurrency
rabbitMQ concurrency issue fixed
2 parents b2074d0 + 21d7b39 commit 3c445e1

File tree

3 files changed

+2
-5
lines changed

3 files changed

+2
-5
lines changed

package-lock.json

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/utils/rabbitmq.mjs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ export default {
1212

1313
// publish message to a queue
1414
async sendMessage(queue, data, options = {}) {
15-
await this.channel.assertQueue(queue);
1615
this.channel.sendToQueue(queue, Buffer.from(JSON.stringify(data)), options);
1716
},
1817

test/queue.mjs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,7 @@ const fileToBuffer = filename => {
2525
});
2626
};
2727

28-
const generateUuid = () => `${Math.random().toString()}
29-
${Math.random().toString()}
30-
${Math.random().toString()}`;
28+
const generateUuid = () => `${Math.random()}${Math.random()}${Math.random()}`;
3129

3230
const { expect } = chai;
3331
let file;

0 commit comments

Comments
 (0)