v0.11 RC, submit for tests

README.md

@@ -25,3 +25,7 @@ The project is actively maintained and used in a commercial project. Tests can r
 either on Vagrant (Vagrantfile attached) or Travis CI, and run against RabbitMQ.
 
 Enjoy!
+
+# Changelog
+
+* v0.11 - added *no_ack* to *consume*, can pass other non-text types to Message
\ No newline at end of file

tests/test_noack.py

@@ -67,19 +67,19 @@ class TestNoAcknowledge(unittest.TestCase):
         self.amqp.qos(0, 1)
 
         self.amqp.consume(myq, no_ack=True)
-        self.amqp.consume(my2)
+        self.amqp.consume(my2).result()
 
-        self.amqp.send(Message(b'what the fuck'), '', routing_key='myqueue')
-        self.amqp.send(Message(b'what the fuck'), '', routing_key='myqueue')
-        self.amqp.send(Message(b'what the fuck'), '', routing_key='myqueue')
+        self.amqp.send(Message(b''), routing_key='myqueue')
+        self.amqp.send(Message(b''), routing_key='myqueue')
+        self.amqp.send(Message(b''), routing_key='myqueue')
 
-        self.amqp.send(Message(b'what the fuck'), '', routing_key='myqueue2')
-        self.amqp.send(Message(b'what the fuck'), '', routing_key='myqueue2')
-        self.amqp.send(Message(b'what the fuck'), '', routing_key='myqueue2')
+        self.amqp.send(Message(b''), routing_key='myqueue2')
+        self.amqp.send(Message(b''), routing_key='myqueue2')
+        self.amqp.send(Message(b''), routing_key='myqueue2')
 
         our_message = None
         for i in range(4):
-            mer = self.amqp.drain(wait=1)
+            mer = self.amqp.drain(wait=2)
             self.assertIsInstance(mer, MessageReceived)
             if mer.message.routing_key == 'myqueue2':
                 self.assertIsNone(our_message)