Update script for testing rabbitmq connections

scripts/test-rabbitmq.connection.py

@@ -2,27 +2,33 @@
 import pika
 import logging
 
+import os
+
+connection_string = os.getenv(
+    "RABBITMQ_URL", default="amqp://guest:guest@localhost:5672"
+)
+
 # create our logger
 logger = logging.getLogger(__name__)
 
-# make sure have the logger set to level to 
+# make sure have the logger set to level to
 # accept the logging statements
 logger.setLevel(logging.DEBUG)
 
-# create a handler for our logs, so we can see them 
+# create a handler for our logs, so we can see them
 console = logging.StreamHandler()
 # add the handler, so logs are shared as stream to STDOUT
 logger.addHandler(console)
 
-connection = pika.BlockingConnection(
-    pika.URLParameters("amqp://guest:guest@localhost:5672")
-)
+connection = pika.BlockingConnection(pika.URLParameters(connection_string))
 
-# we need a channel to sent things to 
+# we need a channel to sent things to
 channel = connection.channel()
 channel.queue_declare(queue="hello")
 
 channel.basic_publish(exchange="", routing_key="hello", body="Hello World!")
 
 logger.info(" [x] Sent 'Hello World!'")
 connection.close()
+
+print(" [x] Sent 'Hello World!'")