code modification.

CUBigDataClass · Apr 13, 2022 · 902230d · 902230d
1 parent 1e775fe
commit 902230d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/emitlogsBackend.py b/emitlogsBackend.py
@@ -5,6 +5,7 @@
 import os
 import sys
 import platform
+import mongodb
 
 # declaring the routing keys for different topics - info/warning/debug
 infoKey = f"{platform.node()}.logs.info"
@@ -21,7 +22,6 @@ def fetchConnection():
         rabbitMQ = pika.BlockingConnection(
                 pika.ConnectionParameters(host=rabbitMQHost, heartbeat=0))
         rabbitMQChannel = rabbitMQ.channel()
-        #print(rabbitMQChannel)
         rabbitMQChannel.exchange_declare(exchange='backendlogs', exchange_type='topic')
         return rabbitMQChannel, rabbitMQ
 

diff --git a/sampleEmitlogsBackend.py b/sampleEmitlogsBackend.py
@@ -3,7 +3,7 @@
 # Step 1: Import emitlogsBackend python file
 import emitlogsBackend
 
-# Step 2: Use two variables <var1> and <var2> to fetch connection and rabbitMQ details
+# Step 2: Use two variables <var1> and <var2> to fetch "rabbitMQ connection" and "rabbitMQ client" details
 rabbitMQChannel, rabbitMQ = emitlogsBackend.fetchConnection()
 
 # Step 3: Use respective function calls to publish your respective info/debug/warning log messages into rabbitMQ backend queue