v2.1.0

coolamqp/__init__.py

-__version__ = '2.1.0a1'
+__version__ = '2.1.0'

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

docs/frames.rst

 ===========================
 Glossary of all AMQP frames
 ===========================
+
+Please note that this is automatically generated.
 .. autoclass:: coolamqp.framing.definitions.ConnectionBlocked
     :members:
 

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

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.

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