init

mini_queue/get_from_queue.py

@@ -0,0 +1,24 @@
+import pika
+
+
+def get_message(parameters):
+    def callback(ch, method, properties, body):
+        print(" [x] Received %r" % body)
+    
+    connection = pika.BlockingConnection(parameters)
+    channel = connection.channel()
+    channel.queue_declare(queue="test", durable=True)
+    channel.basic_consume(queue='test',
+                          auto_ack=True,
+                          on_message_callback=callback) 
+    print(' [*] Waiting for messages. To exit press CTRL+C')
+    channel.start_consuming()
+
+
+if __name__ == "__main__":
+
+    credentials = pika.PlainCredentials('user', 'bitnami')
+    parameters = pika.ConnectionParameters(host="172.17.0.2", port=5672, heartbeat=0, credentials=credentials)
+    get_message(parameters)
+
+

mini_queue/pikapika.py

@@ -1,4 +0,0 @@
-import pika
-
-credentials = pika.PlainCredentials('user', 'bitnami')
-parameters = pika.ConnectionParameters(host=args.host, port=5672, heartbeat=1000, credentials=credentials)

mini_queue/put_on_queue.py

@@ -0,0 +1,19 @@
+import pika
+
+
+def put_message(parameters):
+    connection = pika.BlockingConnection(parameters)
+    channel = connection.channel()
+    channel.queue_declare(queue="test", durable=True)
+    channel.basic_publish('',
+                          'test',
+                          'Hello Wald!')
+    print(" [x] Sent 'Hello World!'")
+    connection.close()
+
+
+if __name__ == "__main__":
+
+    credentials = pika.PlainCredentials('user', 'bitnami')
+    parameters = pika.ConnectionParameters(host="172.17.0.2", port=5672, heartbeat=1000, credentials=credentials)
+    put_message(parameters)