diff --git a/mini_queue/get_from_queue.py b/mini_queue/get_from_queue.py new file mode 100644 index 0000000..56b0537 --- /dev/null +++ b/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) + + diff --git a/mini_queue/pikapika.py b/mini_queue/pikapika.py deleted file mode 100644 index fd27803..0000000 --- a/mini_queue/pikapika.py +++ /dev/null @@ -1,4 +0,0 @@ -import pika - -credentials = pika.PlainCredentials('user', 'bitnami') -parameters = pika.ConnectionParameters(host=args.host, port=5672, heartbeat=1000, credentials=credentials) \ No newline at end of file diff --git a/mini_queue/put_on_queue.py b/mini_queue/put_on_queue.py new file mode 100644 index 0000000..e2f6276 --- /dev/null +++ b/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) \ No newline at end of file