test 1

Tech-Lab-On-Campus/Producer-And-Consumer/producer/solution/producer_sol.py

@@ -0,0 +1,37 @@
+import os
+import pika 
+from producer_interface import mqProducerInterface
+
+class mqProducer(mqProducerInterface): 
+     def __init__(self, routing_key: str, exchange_name: str) -> None:
+        # Save parameters to class variables
+        self.routing_key = routing_key
+        self.exchange_name = exchange_name
+        # Call setupRMQConnection
+        self.setupRMQConnection()
+        pass
+
+     def setupRMQConnection(self) -> None:
+        # Set-up Connection to RabbitMQ service
+        self.con_params = pika.URLParameters(os.environ["AMQP_URL"])
+        self.connection = pika.BlockingConnection(parameters=self.con_params)
+
+        # Establish Channel
+        self.channel = self.connection.channel()
+
+        # Create the exchange if not already present
+        self.exchange = self.channel.exchange_declare(exchange="Exchange Name")
+        pass
+
+     def publishOrder(self, message: str) -> None:
+        # Basic Publish to Exchange
+        self.channel.basic_publish(
+            self.exchange,
+            self.routing_key,
+            body=message)
+
+        # Close Channel
+        self.channel.close()
+        # Close Connection
+        self.connection.close()
+        pass