e-roux · November 30, 2020 22:30 · Nov 30, 2020 · Nov 30, 2020 · Nov 30, 2020 · Nov 30, 2020
diff --git a/receive.py b/receive.py
@@ -23,4 +23,9 @@ def callback(ch, method, properties, body):
         try:
             sys.exit(0)
         except SystemExit:
-            os._exit(0)#!/usr/bin/env python
+            os._exit(0)#!/usr/bin/env python
+
+
+
+
+
diff --git a/receive.py b/receive.py
@@ -1,16 +1,26 @@
 #!/usr/bin/env python
-import pika
+import pika, sys, os
 
+def main():
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
+    channel = connection.channel()
 
-def callback(ch, method, properties, body):
-    print(f" [x] Received {body:r}":)
+    channel.queue_declare(queue='hello')
 
+    def callback(ch, method, properties, body):
+        print(" [x] Received %r" % body)
 
-with pika.BlockingConnection(pika.ConnectionParameters("localhost")) as connection:
-    channel = connection.channel()
+    channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
-    channel.queue_declare(queue="hello")
-    channel.basic_consume(queue="hello", auto_ack=True, on_message_callback=callback)
+    print(' [*] Waiting for messages. To exit press CTRL+C')
+    channel.start_consuming()
 
-    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)#!/usr/bin/env python
diff --git a/receive.py b/receive.py
@@ -3,7 +3,7 @@
 
 
 def callback(ch, method, properties, body):
-    print(" [x] Received %r" % body)
+    print(f" [x] Received {body:r}":)
 
 
 with pika.BlockingConnection(pika.ConnectionParameters("localhost")) as connection:

diff --git a/receive.py b/receive.py
@@ -10,7 +10,6 @@ def callback(ch, method, properties, body):
     channel = connection.channel()
 
     channel.queue_declare(queue="hello")
-
     channel.basic_consume(queue="hello", auto_ack=True, on_message_callback=callback)
 
     print(" [*] Waiting for messages. To exit press CTRL+C")

diff --git a/receive.py b/receive.py
@@ -0,0 +1,17 @@
+#!/usr/bin/env python
+import pika
+
+
+def callback(ch, method, properties, body):
+    print(" [x] Received %r" % body)
+
+
+with pika.BlockingConnection(pika.ConnectionParameters("localhost")) as connection:
+    channel = connection.channel()
+
+    channel.queue_declare(queue="hello")
+
+    channel.basic_consume(queue="hello", auto_ack=True, on_message_callback=callback)
+
+    print(" [*] Waiting for messages. To exit press CTRL+C")
+    channel.start_consuming()
diff --git a/send.py b/send.py
@@ -0,0 +1,20 @@
+#!/usr/bin/env python
+import argparse
+
+import pika
+
+parser = argparse.ArgumentParser(description="Message to send")
+parser.add_argument("msg", metavar="msg", nargs="+", type=list, help="a message to send to the queue ")
+
+args = parser.parse_args()
+
+MESSAGE = " ".join(["".join(w) for w in args.msg])
+
+
+with pika.BlockingConnection(pika.ConnectionParameters("localhost")) as connection:
+    channel = connection.channel()
+
+    channel.queue_declare(queue="hello")
+
+    channel.basic_publish(exchange="", routing_key="hello", body=MESSAGE)
+    print(f" [x] Sent '{MESSAGE}'")
No results found