From 7ba1b039ca5b921feb4e9f2d55db1d7c3bdc1490 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:52:09 +0100
Subject: [PATCH] critical bug
---
coolamqp/cluster.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/coolamqp/cluster.py b/coolamqp/cluster.py
index e29fa91..1618650 100644
--- a/coolamqp/cluster.py
+++ b/coolamqp/cluster.py
@@ -2,6 +2,7 @@
import itertools
from six.moves import queue as Queue
from coolamqp.backends import PyAMQPBackend
+from coolamqp.backends.base import Discarded
from coolamqp.orders import SendMessage, ConsumeQueue, DeclareExchange, CancelQueue, DeleteQueue, \
DeleteExchange, SetQoS, DeclareQueue, Order
from coolamqp.messages import Exchange
@@ -83,7 +84,7 @@ class Cluster(object):
from .handler import ClusterHandlerThread
self.thread = ClusterHandlerThread(self)
- def send(self, message, exchange='', routing_key='', discard_on_fail=False, on_completed=None, on_failed=None):
+ def send(self, message, exchange=None, routing_key='', discard_on_fail=False, on_completed=None, on_failed=None):
"""
Schedule a message to be sent.
:param message: Message object to send.
@@ -98,6 +99,7 @@ class Cluster(object):
a = SendMessage(message, exchange or Exchange.direct, routing_key,
discard_on_fail=discard_on_fail,
on_completed=on_completed, on_failed=on_failed)
+
if discard_on_fail and self.thread.backend is None:
o = Order()
o.discarded = True
--
GitLab