POC completed

1 files changed, 0 insertions, 48 deletions

diff --git a/webapp/rmq.py b/webapp/rmq.py
deleted file mode 100644
index 80d418a..0000000
--- a/webapp/rmq.py
+++ /dev/null
@@ -1,48 +0,0 @@
-import os
-import pika
-
-USERNAME      = 'guest'
-PASSWORD      = 'guest'
-HOST          = os.environ.get('RMQ_HOST', '172.17.0.2')
-PORT          = 5672
-EXCHANGE      = 'exchange'
-EXCHANGE_TYPE = 'direct'
-QUEUE         = 'text'
-ROUTING_KEY   = 'bacon'
-
-try:
-    import docker
-    client = docker.from_env()
-    containers = client.containers.get('snekbox_pdrmq_1')
-    print("Attempting to get rabbitmq host automatically")
-    HOST = list(containers.attrs.get('NetworkSettings').get('Networks').values())[0]['IPAddress']
-    print(f"found {HOST}")
-except:
-    pass
-
-def send(message):
-    credentials = pika.PlainCredentials(USERNAME, PASSWORD)
-    connection = pika.BlockingConnection(pika.ConnectionParameters(HOST, PORT, '/', credentials))
-    properties = pika.BasicProperties(content_type='text/plain', delivery_mode=1)
-
-    channel = connection.channel()
-    channel.queue_declare(queue=QUEUE, durable=False)
-    channel.exchange_declare(exchange=EXCHANGE, exchange_type=EXCHANGE_TYPE)
-    channel.queue_bind(exchange=EXCHANGE, queue=QUEUE, routing_key=ROUTING_KEY)
-
-    result = channel.basic_publish(
-                exchange=EXCHANGE,
-                routing_key=ROUTING_KEY,
-                body=message,
-                properties=properties
-    )
-
-    if result:
-        print(f"""Connecting to\nhost:     {HOST}\nport:     {PORT}\nexchange: {EXCHANGE}\nqueue:    {QUEUE}""", flush=True)
-        print(f"Sent: '{message}'")
-    else:
-        print("not delivered")
-
-    connection.close()
-
-#send('print("bacon is delicious")')