From fb46d48392e3cf9defe71fe2d385ab9209f7c048 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 17:48:55 +0100 Subject: [PATCH] fast fix --- coolamqp/orders.py | 3 ++- tests/test_basics.py | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/coolamqp/orders.py b/coolamqp/orders.py index 877253f..181f77d 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 70f19b1..b0051c6 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): -- GitLab