From d235129e133badfe958548b6cbe291af4ba06768 Mon Sep 17 00:00:00 2001
From: Piotr Maslanka <piotr.maslanka@henrietta.com.pl>
Date: Sun, 29 Jan 2017 20:56:31 +0100
Subject: [PATCH] v0.89
---
coolamqp/attaches/consumer.py | 8 +++++---
setup.py | 2 +-
2 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py
index 39ec99e..1e24203 100644
--- a/coolamqp/attaches/consumer.py
+++ b/coolamqp/attaches/consumer.py
@@ -7,9 +7,8 @@ import warnings
from coolamqp.framing.frames import AMQPBodyFrame, AMQPHeaderFrame
from coolamqp.framing.definitions import ChannelOpenOk, BasicConsume, \
BasicConsumeOk, QueueDeclare, QueueDeclareOk, ExchangeDeclare, ExchangeDeclareOk, \
- QueueBind, QueueBindOk, ChannelClose, BasicCancel, BasicDeliver, \
- BasicAck, BasicReject, RESOURCE_LOCKED, BasicCancelOk, BasicQos, HARD_ERRORS, \
- BasicCancel, BasicQosOk
+ QueueBind, QueueBindOk, ChannelClose, BasicDeliver, BasicCancel, \
+ BasicAck, BasicReject, RESOURCE_LOCKED, BasicCancelOk, BasicQos, BasicQosOk
from coolamqp.uplink import HeaderOrBodyWatch, MethodWatch
from concurrent.futures import Future
from coolamqp.objects import Callable
@@ -64,6 +63,9 @@ class Consumer(Channeler):
fucking_memoryviews=False
):
"""
+ Note that if you specify QoS, it is applied before basic.consume is sent. This will prevent
+ the broker from hammering you into oblivion with a mountain of messages.
+
:param queue: Queue object, being consumed from right now.
Note that name of anonymous queue might change at any time!
:param on_message: callable that will process incoming messages
diff --git a/setup.py b/setup.py
index 46dd47b..141f331 100644
--- a/setup.py
+++ b/setup.py
@@ -25,7 +25,7 @@ setup(name=u'CoolAMQP',
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''',
- requires=['amqp', 'six', 'monotonic'],
+ requires=['six', 'monotonic', 'futures'],
tests_require=["nose"],
test_suite='nose.collector',
classifiers=[
--
GitLab