fix tests

CHANGELOG.md

+# v0.100:
+
+* significant docs update
+* cosmetics
+
+# v0.99:
+
+* *bugfix release*: extra requirements added to [setup.py](/setup.py)
+
 # v0.98:
 
 * *bugfix release*: fixed multiple race conditions, added stress tests

setup.py

@@ -8,10 +8,10 @@ setup(keywords=['amqp', 'rabbitmq', 'client', 'network', 'ha', 'high availabilit
       long_description=u'''Pure Python AMQP client, but with dynamic class generation and memoryviews FOR THE GODSPEED.
 
 Also, handles your reconnects and transactionality THE RIGHT WAY, though somewhat opinionated''',
-      install_requires=['six', 'monotonic', 'futures'],
+      install_requires=['six', 'monotonic', 'futures', 'typing'],
       # per coverage version for codeclimate-reporter
       tests_require=["nose", 'coverage>=4.0,<4.4'],
       test_suite='nose.collector'
-     )
+      )
 
 

tests/test_clustering/test_a.py

@@ -207,7 +207,7 @@ class TestA(unittest.TestCase):
         self.assertEquals(m.body[0], data)
 
         data = six.binary_type(os.urandom(512 * 1024))
-        self.c.publish(Message(data), routing_key=u'hello7', confirm=True)
+        self.c.publish(Message(data), routing_key=u'hello8', confirm=True)
         m = self.c.drain(5)
         self.assertIsInstance(m, MessageReceived)
         self.assertTrue(all([isinstance(x, memoryview) for x in m.body]))