From 95d36df12b592110291caf56d9c541f0e14f66e8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Wed, 13 Nov 2024 17:39:14 +0100
Subject: [PATCH] v2.1.0
---
coolamqp/__init__.py | 2 +-
coolamqp/attaches/consumer.py | 6 ++----
docs/frames.rst | 2 ++
docs/how-to-guide.rst | 6 +++---
docs/whatsnew.rst | 2 +-
setup.cfg | 2 +-
6 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py
index 3fbef98..a33997d 100644
--- a/coolamqp/__init__.py
+++ b/coolamqp/__init__.py
@@ -1 +1 @@
-__version__ = '2.1.0a1'
+__version__ = '2.1.0'
diff --git a/coolamqp/attaches/consumer.py b/coolamqp/attaches/consumer.py
index ddf40ab..80797c6 100644
--- a/coolamqp/attaches/consumer.py
+++ b/coolamqp/attaches/consumer.py
@@ -106,7 +106,7 @@ class Consumer(Channeler):
:type fail_on_first_time_resource_locked: bool
:param body_receive_mode: how should message.body be received. This
has a performance impact
- :type body_receive_mode: a property of :classs:`BodyReceiveMode`
+ :type body_receive_mode: a property of :class:`BodyReceiveMode`
:param arguments: a dictionary, extra set of arguments to be provided to RabbitMQ during binding.
Primarily to support streams.
"""
@@ -231,8 +231,7 @@ class Consumer(Channeler):
self.receiver.on_gone()
self.receiver = None
- def on_close(self, payload=None):
- # type: (tp.Optional[coolamqp.framing.base.AMQPMethodPayload]) -> None
+ def on_close(self, payload=None): # type: (tp.Optional[coolamqp.framing.base.AMQPMethodPayload]) -> None
"""
Handle closing the channel. It sounds like an exception...
@@ -244,7 +243,6 @@ class Consumer(Channeler):
hannel has been physically torn down
Note, this can be called multiple times, and eventually with None.
-
"""
if not self.cancelled:
self.cancelled = True
diff --git a/docs/frames.rst b/docs/frames.rst
index fac9537..972e9ea 100644
--- a/docs/frames.rst
+++ b/docs/frames.rst
@@ -1,6 +1,8 @@
===========================
Glossary of all AMQP frames
===========================
+
+Please note that this is automatically generated.
.. autoclass:: coolamqp.framing.definitions.ConnectionBlocked
:members:
diff --git a/docs/how-to-guide.rst b/docs/how-to-guide.rst
index 48055ba..ef0ebfa 100644
--- a/docs/how-to-guide.rst
+++ b/docs/how-to-guide.rst
@@ -92,11 +92,11 @@ server. However, not providing a
.. autoclass:: coolamqp.attaches.Consumer
:members:
+.. _anonymq:
+
Declaring anonymous queue
-------------------------
-.. _anonymq:
-
In order to make use of an anonymous queue, you must first :meth:`coolamqp.clustering.Cluster.consume` it, since
:meth:`coolamqp.clustering.Cluster.declare` will use a separate channel, in which the queue will be invalid. It will
raise ValueError if you try to do that, anyway.
@@ -106,7 +106,7 @@ Anonymous queues must be auto_delete and exclusive, ValueError will be raised ot
Who am I talking to?
--------------------
-To identify the server you're talking to just connect and use :meth:`coolamqp.clustering.Cluster.properties`,
+To identify the server you're talking to just connect and use :attr:`coolamqp.clustering.Cluster.properties`,
which will return the following class:
.. autoclass:: coolamqp.objects.ServerProperties
diff --git a/docs/whatsnew.rst b/docs/whatsnew.rst
index 1757077..66771af 100644
--- a/docs/whatsnew.rst
+++ b/docs/whatsnew.rst
@@ -32,4 +32,4 @@ Anonymous queues
----------------
They are back. Besides, anything that you will pass to :meth:`coolamqp.clustering.Cluster.consume` will be declared, be
-it an exchange, a queue or such shit. This allows you to declare anonymous queues.
+it an exchange, a queue or such shit. This allows you to declare anonymous queues. Refer to :ref:`anonymq` on how to do it.
diff --git a/setup.cfg b/setup.cfg
index e49e177..eaf08e2 100644
--- a/setup.cfg
+++ b/setup.cfg
@@ -24,7 +24,7 @@ classifiers =
description = Very fast pure-Python AMQP client
author = Piotr MaĹlanka
author_email = pmaslanka@smok.co
-url = https://github.com/smok-serwis/coolamqp
+url = https://git.dms-serwis.com.pl/smokserwis/coolamqp
platforms =
posix
win32
--
GitLab