diff --git a/CHANGELOG.md b/CHANGELOG.md index f275b3076c1457957bfe11c88304a321062558df..1da08cd6ded216bed2491a57084d925346b17b6a 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,13 +1,12 @@ # v1.0.3: -* _TBA_ +* declare *connection.blocked* in *capabilities* # v1.0.2: * **bugfix release** due to some bad flags in setup.py it was impossible to install CoolAMQP on Python 3 - # v1.0.1: * added support for channel flow control and blocking and diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py index 94869735b1ea3f767e5a45e6567bf46c09307434..72d1b4f9fc0a4ba5c94e36dccd957e684562a0e9 100644 --- a/coolamqp/__init__.py +++ b/coolamqp/__init__.py @@ -1,2 +1,2 @@ # coding=UTF-8 -__version__ = '1.0.3_a1' +__version__ = '1.0.3' diff --git a/coolamqp/uplink/handshake.py b/coolamqp/uplink/handshake.py index 4bf04737de6c06e7bbecb5edd51ea80c3c340e16..eb5a87c5a84facfc0ec7f3261a7e63e9f1b200b7 100644 --- a/coolamqp/uplink/handshake.py +++ b/coolamqp/uplink/handshake.py @@ -17,10 +17,12 @@ from coolamqp import __version__ PUBLISHER_CONFIRMS = b'publisher_confirms' CONSUMER_CANCEL_NOTIFY = b'consumer_cancel_notify' +CONNECTION_BLOCKED = b'connection.blocked' SUPPORTED_EXTENSIONS = [ PUBLISHER_CONFIRMS, - CONSUMER_CANCEL_NOTIFY + CONSUMER_CANCEL_NOTIFY, + CONNECTION_BLOCKED # half assed support - we just .cancel the consumer, see #12 ]