From 819e9223d80a7419d5badc837be492f99a2d5580 Mon Sep 17 00:00:00 2001
From: "angelinatingaeva@yandex.ru" <angelina@heado.ru>
Date: Mon, 12 Feb 2024 01:13:52 +0500
Subject: [PATCH] create(queue): only start, but it works!

---
 rabbitmq/receive.py | 27 +++++++++++++++++++++++++++
 rabbitmq/send.py    | 14 ++++++++++++++
 2 files changed, 41 insertions(+)
 create mode 100644 rabbitmq/receive.py
 create mode 100644 rabbitmq/send.py

diff --git a/rabbitmq/receive.py b/rabbitmq/receive.py
new file mode 100644
index 0000000..9e8e81a
--- /dev/null
+++ b/rabbitmq/receive.py
@@ -0,0 +1,27 @@
+import pika, sys, os
+
+def main():
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+    channel = connection.channel()
+
+    channel.queue_declare(queue='bitrix24')
+    
+    def callback(ch, method, properties, body):
+        print(f'[x] Received {body}')
+    
+    channel.basic_consume(queue='bitrix24',
+                          on_message_callback=callback,
+                          auto_ack=True)
+    
+    print(' [*] Waiting for messages. To exit press CTRL+C')
+    channel.start_consuming()
+
+if __name__ == '__main__':
+    try:
+        main()
+    except KeyboardInterrupt:
+        print('Interrupted')
+        try:
+            sys.exit(0)
+        except SystemExit:
+            os._exit(0)
\ No newline at end of file
diff --git a/rabbitmq/send.py b/rabbitmq/send.py
new file mode 100644
index 0000000..01fcc51
--- /dev/null
+++ b/rabbitmq/send.py
@@ -0,0 +1,14 @@
+import pika
+
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+
+channel = connection.channel()
+
+channel.queue_declare(queue='bitrix24')
+
+channel.basic_publish(exchange='',
+                      routing_key='bitrix24',
+                      body='Hello, B24!')
+
+connection.close