diff --git a/README.md b/README.md index 6ca323b9975ba19487f0cc05cf0b95fddebc308b..d8ccb83679594999cda614b960d8ee85781ff62b 100644 --- a/README.md +++ b/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 diff --git a/tests/test_noack.py b/tests/test_noack.py index 3a83f89d1fd8c332b608fa7d5ec1515686391f69..faa5925b29ec56f185a5690420d8589a9eda9937 100644 --- a/tests/test_noack.py +++ b/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)