make RMQ connection protocol configurable (#22)

* make RMQ connection protocol configurable * added RMQ_PROTOCOL to dev env file * added RMQ_PORT in dev env file
shardus · Sep 20, 2024 · 6fe2561 · 6fe2561
1 parent 1bb7c97
commit 6fe2561
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/.env.development b/.env.development
@@ -1,6 +1,8 @@
 HOST='127.0.0.1'
 COLLECTOR_MODE='MQ'
 RMQ_HOST='127.0.0.1'
+RMQ_PORT='5672'
+RMQ_PROTOCOL='amqp'
 RMQ_USER='user'
 RMQ_PASS='pass'
 RMQ_CYCLES_QUEUE_NAME='cycles'

diff --git a/src/messaging/rabbitmq/consumer.ts b/src/messaging/rabbitmq/consumer.ts
@@ -61,7 +61,7 @@ export default class RMQConsumer {
 
   private async connect(): Promise<amqp.Connection> {
     return await amqp.connect({
-      protocol: 'amqp',
+      protocol: process.env.RMQ_PROTOCOL || 'amqp',
       hostname: process.env.RMQ_HOST,
       port: process.env.RMQ_PORT ? parseInt(process.env.RMQ_PORT) : 5672,
       username: process.env.RMQ_USER,