From e90908cdb51b3f2a33bcebfd721b3af4e193df66 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sun, 25 Dec 2016 01:26:23 +0100
Subject: [PATCH] v0.11 RC, submit for tests
---
README.md | 4 ++++
tests/test_noack.py | 16 ++++++++--------
2 files changed, 12 insertions(+), 8 deletions(-)
diff --git a/README.md b/README.md
index 6ca323b..d8ccb83 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 3a83f89..faa5925 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)
--
GitLab