aboutsummaryrefslogtreecommitdiffstats
path: root/runner/publish.py
diff options
context:
space:
mode:
Diffstat (limited to 'runner/publish.py')
-rw-r--r--runner/publish.py42
1 files changed, 0 insertions, 42 deletions
diff --git a/runner/publish.py b/runner/publish.py
deleted file mode 100644
index fc18d03..0000000
--- a/runner/publish.py
+++ /dev/null
@@ -1,42 +0,0 @@
-import pika
-from config import (
- USERNAME,
- PASSWORD,
- HOST,
- PORT,
- EXCHANGE,
- EXCHANGE_TYPE,
- QUEUE,
- ROUTING_KEY,
-)
-
-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
- host: {HOST}
- port: {PORT}
- exchange: {EXCHANGE}
- queue: {QUEUE}""", flush=True)
- print(f"Sent: '{message}'")
- else:
- print("not delivered")
-
- connection.close()
-
-send('print "bacon is delicious"')