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