diff --git a/coolamqp/cluster.py b/coolamqp/cluster.py index 084663ae38e3b27cde92c440361fdf39bc747fef..578ef2aaa79c57c16cd9760e192543d13d2eaa44 100644 --- a/coolamqp/cluster.py +++ b/coolamqp/cluster.py @@ -83,7 +83,7 @@ class Cluster(object): from .handler import ClusterHandlerThread self.thread = ClusterHandlerThread(self) - def send(self, message, exchange=None, routing_key='', on_completed=None, on_failed=None): + def send(self, message, exchange='', routing_key='', on_completed=None, on_failed=None): """ Schedule a message to be sent. :param message: Message object to send diff --git a/setup.py b/setup.py index cf17ea1ca2a21ba06d351c69db4066b9c52eb9b1..3b25fbde548e40c1513690503ff6f58fea19fb55 100644 --- a/setup.py +++ b/setup.py @@ -2,12 +2,6 @@ # coding=UTF-8 from setuptools import setup - -def reqs(): - with open('requirements.txt', 'r') as fin: - return [q.strip() for q in fin.readlines() if len(q.strip()) > 0] - - setup(name='CoolAMQP', version='0.9', description='AMQP client with sane reconnects',