diff --git a/coolamqp/orders.py b/coolamqp/orders.py index 877253f183bd1d01fd3fbbf6781979cc457f46a1..181f77dff5eb1729e5ccd1dc3d192b64e9f081e9 100644 --- a/coolamqp/orders.py +++ b/coolamqp/orders.py @@ -95,10 +95,11 @@ class Order(object): class SendMessage(Order): """Send a message""" - def __init__(self, message, exchange, routing_key, on_completed=None, on_failed=None): + def __init__(self, message, exchange, routing_key, discard_on_fail=False, on_completed=None, on_failed=None): Order.__init__(self, on_completed=on_completed, on_failed=on_failed) self.message = message self.exchange = exchange + self.discard_on_fail = discard_on_fail self.routing_key = routing_key diff --git a/tests/test_basics.py b/tests/test_basics.py index 70f19b1d212ff53b069b59d0694fecf1782d0823..b0051c672514ac182a59d92607b706d6382d9a39 100644 --- a/tests/test_basics.py +++ b/tests/test_basics.py @@ -17,6 +17,8 @@ class TestThings(CoolAMQPTestCase): amqp.shutdown() +#todo discard on fail needs tests + class TestBasics(CoolAMQPTestCase): def test_acknowledge(self):