diff --git a/README.md b/README.md
index b8081912f4dd7a1de4fbd49a67dcdbe98a7f606d..fb399c81d0614b7c88c75795febe85b407dffc61 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 a74ed45239fd8fa522f0d77fa9f6019794536c58..c8cd4a66b7435addab63e4843c53bfb3a98954ec 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, )