From ed74273d3dacbe393c1e717e35dce0b86cc3fede Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sat, 28 May 2016 01:30:57 +0200
Subject: [PATCH] example adjusted
---
README.md | 2 +-
examples/send_to_myself.py | 9 ++++-----
2 files changed, 5 insertions(+), 6 deletions(-)
diff --git a/README.md b/README.md
index b808191..fb399c8 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,4 @@
-coolamqp
+CoolAMQP
========
When you're tired of fucking with AMQP reconnects.
diff --git a/examples/send_to_myself.py b/examples/send_to_myself.py
index a74ed45..c8cd4a6 100644
--- a/examples/send_to_myself.py
+++ b/examples/send_to_myself.py
@@ -1,4 +1,4 @@
-from coolamqp import Cluster, ClusterNode, Queue, Message, ConnectionUp, ConnectionDown, MessageReceived
+from coolamqp import Cluster, ClusterNode, Queue, Message, ConnectionUp, ConnectionDown, MessageReceived, ConsumerCancelled
import logging
import time
@@ -12,13 +12,10 @@ a_queue = Queue(QUEUE_NAME, auto_delete=True)
cluster.consume(a_queue)
q = time.time()
-i = 0
-
while True:
if time.time() - q > 10:
q = time.time()
- cluster.send(Message('hello world '+str(i)), routing_key=QUEUE_NAME)
- i += 1
+ cluster.send(Message('hello world'), routing_key=QUEUE_NAME)
evt = cluster.drain(2)
@@ -29,5 +26,7 @@ while True:
elif isinstance(evt, MessageReceived):
print 'Message is %s' % (evt.message.body, )
evt.message.ack()
+ elif isinstance(evt, ConsumerCancelled):
+ print 'Consumer %s cancelled' % (evt.queue.name, )
--
GitLab