Skip to content

Commit b3da782

Browse files
committed
feat: add b roker
1 parent 381c38b commit b3da782

File tree

4 files changed

+5
-4
lines changed

4 files changed

+5
-4
lines changed

shared/broker/package.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
},
1515
"private": false,
1616
"dependencies": {
17-
"amqplib": "^0.10.4"
17+
"amqplib": "^0.10.4",
18+
"@microservices-suite/utilities": "1.0.6"
1819
}
1920
}

shared/broker/rabbitmq/exchange.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11

22
const amqp = require('amqplib');
3-
const { APIError } = require("@monorepo/utilities");
3+
const { APIError } = require("@microservices-suite/utilities");
44

55
/**
66
* Initializes a connection to the RabbitMQ broker, creates a channel, and asserts an exchange.

shared/broker/rabbitmq/publisher.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
const { APIError } = require("@monorepo/utilities");
2+
const { APIError } = require("@microservices-suite/utilities");
33

44
/**
55
* Publishes a message to a specified exchange with a given routing key.

shared/broker/rabbitmq/worker.queue.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11

22
const amqp = require('amqplib');
3-
const { APIError } = require("@monorepo/utilities");
3+
const { APIError } = require("@microservices-suite/utilities");
44

55
/**
66
* Initializes a connection to the RabbitMQ broker and returns a channel.

0 commit comments

Comments
 (0)