diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py index 3fbef98d59b8db897c47c77c769931ba1b717c86..a33997dd1004d8fb312324a652e27fcab292f4eb 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 ddf40ab99f3bbe23464ecafed18e71b5db12ee6e..80797c617b2274dbb5b7c48d6df420143f32cc47 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 fac953793578fc79bbc56db5d5ba9b6c34cc9b6d..972e9eaa9773ca52403ebbab42a955d66d62e397 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 48055ba8ccbe276206a2ecaa299c49c671a2b765..ef0ebfaec11a68f6a5c3fc8b5c58ed3059fcba90 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 1757077915348433f76bca7adfc863d100fdd702..66771afe9ca185c3362d3f878d8f289fac8d6310 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 e49e177029e6f385ffa953874a9a649a2bb30757..eaf08e232f80a15f86ded1f3bc77d21fff7d9817 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