new message broker ip

newtondotcom · Jan 5, 2024 · e6157f0 · e6157f0
1 parent 78c3da4
commit e6157f0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/fakerabbitmq/receiver.py b/fakerabbitmq/receiver.py
@@ -5,7 +5,7 @@
 print(' Connecting to server ...')
 
 try:
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host="141.145.217.120",port=5672))
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host="144.91.123.186",port=15672))
 except pika.exceptions.AMQPConnectionError as exc:
     print("Failed to connect to RabbitMQ service. Message wont be sent.")
     exit()

diff --git a/fakerabbitmq/sender.py b/fakerabbitmq/sender.py
@@ -10,7 +10,7 @@
 print(' Connecting to server ...')
 
 try:
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host="141.145.217.120",port=5672))
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host="144.91.123.186",port=15672))
 except pika.exceptions.AMQPConnectionError as exc:
     print("Failed to connect to RabbitMQ service. Message wont be sent.")
     exit()

diff --git a/fakerabbitmq/serverjs/index.js b/fakerabbitmq/serverjs/index.js
@@ -1,6 +1,6 @@
 const amqp = require('amqplib');
 
-const rabbitMQUrl = 'amqp://141.145.217.120:5672';
+const rabbitMQUrl = 'amqp://144.91.123.186:15672';
 const exchange = 'tasks';
 const workerQueue = 'task_queue';