echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updated puka tutorial samples.

Browse Source
This commit is contained in:
Marek Majkowski 2011-07-06 13:51:53 +01:00
parent 0afac375df
commit 1f5fd76014
6 changed files with 77 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
python-puka/emit_log.py Executable file
View File

@ -0,0 +1,18 @@
#!/usr/bin/env python
import puka
import sys
client = puka.Client("amqp://localhost/")
promise = client.connect()
client.wait(promise)
promise = client.exchange_declare(exchange='logs', type='fanout')
client.wait(promise)
message = ' '.join(sys.argv[1:]) or "info: Hello World!"
promise = client.basic_publish(exchange='logs', routing_key='', body=message)
client.wait(promise)
print " [x] Sent %r" % (message,)
client.close()

17
python-puka/new_task.py
View File

@ -3,16 +3,19 @@ import puka
import sys
client = puka.Client("amqp://localhost/")
ticket = client.connect()
client.wait(ticket)
promise = client.connect()
client.wait(promise)
ticket = client.queue_declare(queue='task_queue')
client.wait(ticket)
promise = client.queue_declare(queue='task_queue', durable=True)
client.wait(promise)
message = ' '.join(sys.argv[1:]) or "Hello World!"
ticket = client.basic_publish(exchange='',
promise = client.basic_publish(exchange='',
routing_key='task_queue',
body=message)
client.wait(ticket)
body=message,
headers={'delivery_mode': 2})
client.wait(promise)
print " [x] Sent %r" % (message,)
client.close()

16
python-puka/receive.py
View File

@ -2,17 +2,17 @@
import puka
client = puka.Client("amqp://localhost/")
ticket = client.connect()
client.wait(ticket)
promise = client.connect()
client.wait(promise)
ticket = client.queue_declare(queue='hello')
client.wait(ticket)
promise = client.queue_declare(queue='hello')
client.wait(promise)
print ' [*] Waiting for messages. To exit press CTRL+C'
consume_ticket = client.basic_consume(queue='hello',
no_ack=True)
consume_promise = client.basic_consume(queue='hello', no_ack=True)
while True:
msg_result = client.wait(consume_ticket)
print " [x] Received %r %r" % (msg_result['body'], msg_result,)
msg_result = client.wait(consume_promise)
print " [x] Received %r" % (msg_result['body'],)

24
python-puka/receive_logs.py Executable file
View File

@ -0,0 +1,24 @@
#!/usr/bin/env python
import puka
client = puka.Client("amqp://localhost/")
promise = client.connect()
client.wait(promise)
promise = client.exchange_declare(exchange='logs', type='fanout')
client.wait(promise)
promise = client.queue_declare(exclusive=True)
queue_name = client.wait(promise)['queue']
promise = client.queue_bind(exchange='logs', queue=queue_name)
client.wait(promise)
print ' [*] Waiting for logs. To exit press CTRL+C'
consume_promise = client.basic_consume(queue=queue_name, no_ack=True)
while True:
msg_result = client.wait(consume_promise)
print " [x] %r" % (msg_result['body'],)

17
python-puka/send.py
View File

@ -2,16 +2,17 @@
import puka
client = puka.Client("amqp://localhost/")
ticket = client.connect()
client.wait(ticket)
promise = client.connect()
client.wait(promise)
ticket = client.queue_declare(queue='hello')
client.wait(ticket)
ticket = client.basic_publish(exchange='',
promise = client.queue_declare(queue='hello')
client.wait(promise)
promise = client.basic_publish(exchange='',
routing_key='hello',
body="Hello world!")
client.wait(ticket)
body="Hello World!")
client.wait(promise)
print " [x] Sent 'Hello World!'"
client.close()

17
python-puka/worker.py
View File

@ -3,21 +3,18 @@ import puka
import time
client = puka.Client("amqp://localhost/")
ticket = client.connect()
client.wait(ticket)
promise = client.connect()
client.wait(promise)
ticket = client.queue_declare(queue='task_queue')
client.wait(ticket)
promise = client.queue_declare(queue='task_queue', durable=True)
client.wait(promise)
print ' [*] Waiting for messages. To exit press CTRL+C'
consume_ticket = client.basic_consume(queue='task_queue',
prefetch_count=1)
consume_promise = client.basic_consume(queue='task_queue', prefetch_count=1)
while True:
msg_result = client.wait(consume_ticket)
body = msg_result['body']
print " [x] Received %r" % (body,)
msg_result = client.wait(consume_promise)
print " [x] Received %r" % (msg_result['body'],)
time.sleep( body.count('.') )
print " [x] Done"
client.basic_ack(msg_result)