Mailinglist Archive: opensuse-commit (1903 mails)

< Previous Next >
commit python-pika for openSUSE:Factory
Hello community,

here is the log from the commit of package python-pika for openSUSE:Factory
checked in at 2019-04-19 18:39:06
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Comparing /work/SRC/openSUSE:Factory/python-pika (Old)
and /work/SRC/openSUSE:Factory/.python-pika.new.5536 (New)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

Package is "python-pika"

Fri Apr 19 18:39:06 2019 rev:13 rq:695707 version:1.0.1

Changes:
--------
--- /work/SRC/openSUSE:Factory/python-pika/python-pika.changes 2019-04-08
20:53:50.350581703 +0200
+++ /work/SRC/openSUSE:Factory/.python-pika.new.5536/python-pika.changes
2019-04-19 18:39:29.671269412 +0200
@@ -1,0 +2,7 @@
+Thu Apr 18 12:56:39 UTC 2019 - Ondřej Súkup <mimi.vx@xxxxxxxxx>
+
+- update to 1.0.1
+ * API docstring updates
+ * Twisted adapter: Add basic_consume Deferred to the call list
+
+-------------------------------------------------------------------

Old:
----
1.0.0.tar.gz

New:
----
1.0.1.tar.gz

++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

Other differences:
------------------
++++++ python-pika.spec ++++++
--- /var/tmp/diff_new_pack.vn2TLF/_old 2019-04-19 18:39:31.291271470 +0200
+++ /var/tmp/diff_new_pack.vn2TLF/_new 2019-04-19 18:39:31.307271490 +0200
@@ -19,7 +19,7 @@
%define mod_name pika
%{?!python_module:%define python_module() python-%{**} python3-%{**}}
Name: python-%{mod_name}
-Version: 1.0.0
+Version: 1.0.1
Release: 0
Summary: Pika Python AMQP Client Library
License: BSD-3-Clause

++++++ 1.0.0.tar.gz -> 1.0.1.tar.gz ++++++
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/CHANGELOG.rst new/pika-1.0.1/CHANGELOG.rst
--- old/pika-1.0.0/CHANGELOG.rst 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/CHANGELOG.rst 2019-04-12 19:45:56.000000000 +0200
@@ -1,6 +1,14 @@
Version History
===============

+1.0.1 2019-04-12
+----------------
+
+`GitHub milestone <https://github.com/pika/pika/milestone/15?closed=1>`_
+
+- API docstring updates
+- Twisted adapter: Add basic_consume Deferred to the call list (`PR
<https://github.com/pika/pika/pull/1202>`_)
+
1.0.0 2019-03-26
----------------

diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/docs/examples/twisted_example.rst
new/pika-1.0.1/docs/examples/twisted_example.rst
--- old/pika-1.0.0/docs/examples/twisted_example.rst 2019-03-27
01:39:32.000000000 +0100
+++ new/pika-1.0.1/docs/examples/twisted_example.rst 2019-04-12
19:45:56.000000000 +0200
@@ -1,49 +1,5 @@
Twisted Consumer Example
========================
-Example of writing a consumer using the :py:class:`Twisted connection adapter
<pika.adapters.twisted_connection.TwistedProtocolConnection>`::
+Example of writing an application using the :py:class:`Twisted connection
adapter <pika.adapters.twisted_connection.TwistedProtocolConnection>`::.

- # -*- coding:utf-8 -*-
-
- import pika
- from pika import exceptions
- from pika.adapters import twisted_connection
- from twisted.internet import defer, reactor, protocol,task
-
-
- @defer.inlineCallbacks
- def run(connection):
-
- channel = yield connection.channel()
-
- exchange = yield channel.exchange_declare(exchange='topic_link',
exchange_type='topic')
-
- queue = yield channel.queue_declare(queue='hello', auto_delete=False,
exclusive=False)
-
- yield
channel.queue_bind(exchange='topic_link',queue='hello',routing_key='hello.world')
-
- yield channel.basic_qos(prefetch_count=1)
-
- queue_object, consumer_tag = yield channel.basic_consume('hello',
auto_ack=False)
-
- l = task.LoopingCall(read, queue_object)
-
- l.start(0.01)
-
-
- @defer.inlineCallbacks
- def read(queue_object):
-
- ch,method,properties,body = yield queue_object.get()
-
- if body:
- print(body)
-
- yield ch.basic_ack(delivery_tag=method.delivery_tag)
-
-
- parameters = pika.ConnectionParameters()
- cc = protocol.ClientCreator(reactor,
twisted_connection.TwistedProtocolConnection, parameters)
- d = cc.connectTCP('hostname', 5672)
- d.addCallback(lambda protocol: protocol.ready)
- d.addCallback(run)
- reactor.run()
+`Twisted Example
<https://github.com/pika/pika/blob/master/examples/twisted_service.py>`_
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/docs/faq.rst new/pika-1.0.1/docs/faq.rst
--- old/pika-1.0.0/docs/faq.rst 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/docs/faq.rst 2019-04-12 19:45:56.000000000 +0200
@@ -15,4 +15,4 @@

- How can I contribute to Pika?

- You can `fork the project on Github <http://help.github.com/forking/>`_
and issue `Pull Requests <http://help.github.com/pull-requests/>`_ when you
believe you have something solid to be added to the main repository.
+ You can `fork the project on Github
<https://help.github.com/en/articles/fork-a-repo/>`_ and issue `Pull Requests
<https://help.github.com/en/articles/about-pull-requests/>`_ when you believe
you have something solid to be added to the main repository.
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/docs/intro.rst
new/pika-1.0.1/docs/intro.rst
--- old/pika-1.0.0/docs/intro.rst 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/docs/intro.rst 2019-04-12 19:45:56.000000000 +0200
@@ -122,4 +122,4 @@

.. rubric:: Footnotes

-.. [#f1] "more effective flow control mechanism that does not require
cooperation from clients and reacts quickly to prevent the broker from
exhausting memory - see http://www.rabbitmq.com/extensions.html#memsup"; from
http://lists.rabbitmq.com/pipermail/rabbitmq-announce/attachments/20100825/2c672695/attachment.txt
+.. [#f1] "more effective flow control mechanism that does not require
cooperation from clients and reacts quickly to prevent the broker from
exhausting memory - see
http://lists.rabbitmq.com/pipermail/rabbitmq-announce/attachments/20100825/2c672695/attachment.txt
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/docs/version_history.rst
new/pika-1.0.1/docs/version_history.rst
--- old/pika-1.0.0/docs/version_history.rst 2019-03-27 01:39:32.000000000
+0100
+++ new/pika-1.0.1/docs/version_history.rst 2019-04-12 19:45:56.000000000
+0200
@@ -1,6 +1,14 @@
Version History
===============

+1.0.1 2019-04-12
+----------------
+
+`GitHub milestone <https://github.com/pika/pika/milestone/15?closed=1>`_
+
+- API docstring updates
+- Twisted adapter: Add basic_consume Deferred to the call list (`PR
<https://github.com/pika/pika/pull/1202>`_)
+
1.0.0 2019-03-26
----------------

diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/examples/twisted_service.py
new/pika-1.0.1/examples/twisted_service.py
--- old/pika-1.0.0/examples/twisted_service.py 2019-03-27 01:39:32.000000000
+0100
+++ new/pika-1.0.1/examples/twisted_service.py 2019-04-12 19:45:56.000000000
+0200
@@ -67,13 +67,13 @@
host=self.parameters.host,
port=self.parameters.port,
factory=f)
+ serv.factory = f
f.service = serv # pylint: disable=W0201
name = '%s%s:%d' % ('ssl:' if self.parameters.ssl_options else '',
self.parameters.host, self.parameters.port)
serv.__repr__ = lambda: '<AMQP Connection to %s>' % name
serv.setName(name)
- serv.parent = self
- self.addService(serv)
+ serv.setServiceParent(self)


class PikaProtocol(twisted_connection.TwistedProtocolConnection):
@@ -85,11 +85,11 @@
self.factory = factory

@inlineCallbacks
- def onConnected(self, connection):
- self.channel = yield connection.channel()
- yield self.channel.basic_qos(prefetch_count=PREFETCH_COUNT)
+ def connectionReady(self):
+ self._channel = yield self.channel()
+ yield self._channel.basic_qos(prefetch_count=PREFETCH_COUNT)
self.connected = True
- yield self.channel.confirm_delivery()
+ yield self._channel.confirm_delivery()
for (
exchange,
routing_key,
@@ -109,22 +109,22 @@
def setup_read(self, exchange, routing_key, callback):
"""This function does the work to read from an exchange."""
if exchange:
- yield self.channel.exchange_declare(
+ yield self._channel.exchange_declare(
exchange=exchange,
exchange_type='topic',
durable=True,
auto_delete=False)

- yield self.channel.queue_declare(queue=routing_key, durable=True)
+ yield self._channel.queue_declare(queue=routing_key, durable=True)
if exchange:
- yield self.channel.queue_bind(queue=routing_key, exchange=exchange)
- yield self.channel.queue_bind(
+ yield self._channel.queue_bind(queue=routing_key,
exchange=exchange)
+ yield self._channel.queue_bind(
queue=routing_key, exchange=exchange, routing_key=routing_key)

(
queue,
_consumer_tag,
- ) = yield self.channel.basic_consume(
+ ) = yield self._channel.basic_consume(
queue=routing_key, auto_ack=False)
d = queue.get()
d.addCallback(self._read_item, queue, callback)
@@ -170,14 +170,14 @@
log.msg(
'%s (%s): %s' % (exchange, routing_key, repr(msg)),
system='Pika:=>')
- yield self.channel.exchange_declare(
+ yield self._channel.exchange_declare(
exchange=exchange,
exchange_type='topic',
durable=True,
auto_delete=False)
prop = spec.BasicProperties(delivery_mode=2)
try:
- yield self.channel.basic_publish(
+ yield self._channel.basic_publish(
exchange=exchange,
routing_key=routing_key,
body=msg,
@@ -202,7 +202,6 @@
self.resetDelay()
log.msg('Connected', system=self.name)
self.client = PikaProtocol(self, self.parameters)
- self.client.ready.addCallback(self.client.onConnected)
return self.client

def clientConnectionLost(self, connector, reason): # pylint: disable=W0221
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/pika/__init__.py
new/pika-1.0.1/pika/__init__.py
--- old/pika-1.0.0/pika/__init__.py 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/pika/__init__.py 2019-04-12 19:45:56.000000000 +0200
@@ -1,4 +1,4 @@
-__version__ = '1.0.0'
+__version__ = '1.0.1'

import logging

diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/pika/adapters/blocking_connection.py
new/pika-1.0.1/pika/adapters/blocking_connection.py
--- old/pika-1.0.0/pika/adapters/blocking_connection.py 2019-03-27
01:39:32.000000000 +0100
+++ new/pika-1.0.1/pika/adapters/blocking_connection.py 2019-04-12
19:45:56.000000000 +0200
@@ -2310,7 +2310,7 @@
"""Turn on RabbitMQ-proprietary Confirm mode in the channel.

For more information see:
- http://www.rabbitmq.com/extensions.html#confirms
+ https://www.rabbitmq.com/confirms.html
"""
if self._delivery_confirmation:
LOGGER.error(
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/pika/adapters/twisted_connection.py
new/pika-1.0.1/pika/adapters/twisted_connection.py
--- old/pika-1.0.0/pika/adapters/twisted_connection.py 2019-03-27
01:39:32.000000000 +0100
+++ new/pika-1.0.1/pika/adapters/twisted_connection.py 2019-04-12
19:45:56.000000000 +0200
@@ -390,11 +390,12 @@
:param str consumer_tag: Specify your own consumer tag
:param dict arguments: Custom key/value pair arguments for the consumer
:returns: Deferred that fires with a tuple
- ``(queue_object, consumer_tag)``. The queue object is an instance
- of :class:`ClosableDeferredQueue`, where data received from
- the queue will be stored. Clients should use its
- :meth:`get() <ClosableDeferredQueue.get>` method to fetch an
- individual message, which will return a Deferred firing with a
+ ``(queue_object, consumer_tag)``. The Deferred will errback with an
+ instance of :class:`exceptions.ChannelClosed` if the call fails.
+ The queue object is an instance of :class:`ClosableDeferredQueue`,
+ where data received from the queue will be stored. Clients should
+ use its :meth:`get() <ClosableDeferredQueue.get>` method to fetch
+ an individual message, which will return a Deferred firing with a
namedtuple whose attributes are:
- channel: this TwistedChannel
- method: pika.spec.Basic.Deliver
@@ -408,12 +409,14 @@

queue_obj = ClosableDeferredQueue()
d = defer.Deferred()
+ self._calls.add(d)

def on_consume_ok(frame):
consumer_tag = frame.method.consumer_tag
self._queue_name_to_consumer_tags.setdefault(
queue, set()).add(consumer_tag)
self._consumers[consumer_tag] = queue_obj
+ self._calls.discard(d)
d.callback((queue_obj, consumer_tag))

def on_message_callback(_channel, method, properties, body):
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/pika/channel.py
new/pika-1.0.1/pika/channel.py
--- old/pika-1.0.0/pika/channel.py 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/pika/channel.py 2019-04-12 19:45:56.000000000 +0200
@@ -214,9 +214,9 @@
the loss of consumers due to events such as queue deletion.

:param str consumer_tag: Identifier for the consumer
- :param callable callback: Callback to call for a Basic.CancelOk
- response. If None, do not expect a Basic.CancelOk response,
- otherwise, callback must be callable.
+ :param callable callback: callback(pika.frame.Method) for method
+ Basic.CancelOk. If None, do not expect a Basic.CancelOk response,
+ otherwise, callback must be callable

:raises ValueError:

@@ -254,12 +254,11 @@

self._cancelled.add(consumer_tag)

- self._rpc(
- spec.Basic.Cancel(consumer_tag=consumer_tag, nowait=nowait),
- self._on_cancelok if not nowait else None,
- [(spec.Basic.CancelOk, {
- 'consumer_tag': consumer_tag
- })] if not nowait else [])
+ self._rpc(spec.Basic.Cancel(consumer_tag=consumer_tag, nowait=nowait),
+ self._on_cancelok if not nowait else None,
+ [(spec.Basic.CancelOk, {
+ 'consumer_tag': consumer_tag
+ })] if not nowait else [])

def basic_consume(self,
queue,
@@ -322,12 +321,11 @@
rpc_callback = self._on_eventok if callback is None else callback

self._rpc(
- spec.Basic.Consume(
- queue=queue,
- consumer_tag=consumer_tag,
- no_ack=auto_ack,
- exclusive=exclusive,
- arguments=arguments or dict()), rpc_callback,
+ spec.Basic.Consume(queue=queue,
+ consumer_tag=consumer_tag,
+ no_ack=auto_ack,
+ exclusive=exclusive,
+ arguments=arguments or dict()), rpc_callback,
[(spec.Basic.ConsumeOk, {
'consumer_tag': consumer_tag
})])
@@ -426,9 +424,9 @@
body = body.encode('utf-8')
properties = properties or spec.BasicProperties()
self._send_method(
- spec.Basic.Publish(
- exchange=exchange, routing_key=routing_key,
- mandatory=mandatory), (properties, body))
+ spec.Basic.Publish(exchange=exchange,
+ routing_key=routing_key,
+ mandatory=mandatory), (properties, body))

def basic_qos(self,
prefetch_size=0,
@@ -502,13 +500,15 @@
delivering it to an alternative subscriber.
:param callable callback: Callback to call when receiving
Basic.RecoverOk
+ :param callable callback: callback(pika.frame.Method) for method
+ Basic.RecoverOk
:raises ValueError:

"""
self._raise_if_not_open()
validators.rpc_completion_callback(callback)
- return self._rpc(
- spec.Basic.Recover(requeue), callback, [spec.Basic.RecoverOk])
+ return self._rpc(spec.Basic.Recover(requeue), callback,
+ [spec.Basic.RecoverOk])

def close(self, reply_code=0, reply_text="Normal shutdown"):
"""Invoke a graceful shutdown of the channel with the AMQP Broker.
@@ -547,9 +547,8 @@
# ChannelWrongStateError exception from basic_cancel
self._set_state(self.CLOSING)

- self._rpc(
- spec.Channel.Close(reply_code, reply_text, 0, 0), self._on_closeok,
- [spec.Channel.CloseOk])
+ self._rpc(spec.Channel.Close(reply_code, reply_text, 0, 0),
+ self._on_closeok, [spec.Channel.CloseOk])

def confirm_delivery(self, ack_nack_callback, callback=None):
"""Turn on Confirm mode in the channel. Pass in a callback to be
@@ -557,13 +556,13 @@
rejected (Basic.Ack, Basic.Nack) from the broker to the publisher.

For more information see:
- http://www.rabbitmq.com/extensions.html#confirms
+ https://www.rabbitmq.com/confirms.html

:param callable ack_nack_callback: Required callback for delivery
confirmations that has the following signature:
callback(pika.frame.Method), where method_frame contains
either method `spec.Basic.Ack` or `spec.Basic.Nack`.
- :param callable callback: Callback to call when receiving
+ :param callable callback: callback(pika.frame.Method) for method
Confirm.SelectOk
:raises ValueError:

@@ -588,9 +587,8 @@
self.callbacks.add(self.channel_number, spec.Basic.Nack,
ack_nack_callback, False)

- self._rpc(
- spec.Confirm.Select(nowait), callback,
- [spec.Confirm.SelectOk] if not nowait else [])
+ self._rpc(spec.Confirm.Select(nowait), callback,
+ [spec.Confirm.SelectOk] if not nowait else [])

@property
def consumer_tags(self):
@@ -613,7 +611,7 @@
:param str source: The source exchange to bind to
:param str routing_key: The routing key to bind on
:param dict arguments: Custom key/value pair arguments for the binding
- :param callable callback: The callback to call on Exchange.BindOk
+ :param callable callback: callback(pika.frame.Method) for method
Exchange.BindOk
:raises ValueError:

"""
@@ -653,7 +651,7 @@
:param bool auto_delete: Remove when no more queues are bound to it
:param bool internal: Can only be published to by other exchanges
:param dict arguments: Custom key/value pair arguments for the exchange
- :param callable callback: Call this method on Exchange.DeclareOk
+ :param callable callback: callback(pika.frame.Method) for method
Exchange.DeclareOk
:raises ValueError:

"""
@@ -671,15 +669,15 @@

:param str exchange: The exchange name
:param bool if_unused: only delete if the exchange is unused
- :param callable callback: The function to call on Exchange.DeleteOk
+ :param callable callback: callback(pika.frame.Method) for method
Exchange.DeleteOk
:raises ValueError:

"""
self._raise_if_not_open()
nowait = validators.rpc_completion_callback(callback)
- return self._rpc(
- spec.Exchange.Delete(0, exchange, if_unused, nowait), callback,
- [spec.Exchange.DeleteOk] if not nowait else [])
+ return self._rpc(spec.Exchange.Delete(0, exchange, if_unused,
+ nowait), callback,
+ [spec.Exchange.DeleteOk] if not nowait else [])

def exchange_unbind(self,
destination=None,
@@ -693,7 +691,7 @@
:param str source: The source exchange to unbind from
:param str routing_key: The routing key to unbind
:param dict arguments: Custom key/value pair arguments for the binding
- :param callable callback: The callback to call on Exchange.UnbindOk
+ :param callable callback: callback(pika.frame.Method) for method
Exchange.UnbindOk
:raises ValueError:

"""
@@ -713,16 +711,15 @@
http://www.rabbitmq.com/amqp-0-9-1-reference.html#channel.flow

:param bool active: Turn flow on or off
- :param callable callback: The optional callback to call upon
- completion
+ :param callable callback: callback(bool) upon completion
:raises ValueError:

"""
self._raise_if_not_open()
validators.rpc_completion_callback(callback)
self._on_flowok_callback = callback
- self._rpc(
- spec.Channel.Flow(active), self._on_flowok, [spec.Channel.FlowOk])
+ self._rpc(spec.Channel.Flow(active), self._on_flowok,
+ [spec.Channel.FlowOk])

@property
def is_closed(self):
@@ -770,7 +767,7 @@
:param str exchange: The source exchange to bind to
:param str routing_key: The routing key to bind on
:param dict arguments: Custom key/value pair arguments for the binding
- :param callable callback: The callback to call on Queue.BindOk
+ :param callable callback: callback(pika.frame.Method) for method
Queue.BindOk
:raises ValueError:

"""
@@ -808,8 +805,7 @@
:param bool exclusive: Only allow access by the current connection
:param bool auto_delete: Delete after consumer cancels or disconnects
:param dict arguments: Custom key/value arguments for the queue
- :param callable callback: callback(pika.frame.Method) for method
- Queue.DeclareOk
+ :param callable callback: callback(pika.frame.Method) for method
Queue.DeclareOk
:raises ValueError:

"""
@@ -838,7 +834,7 @@
:param str queue: The queue to delete
:param bool if_unused: only delete if it's unused
:param bool if_empty: only delete if the queue is empty
- :param callable callback: The callback to call on Queue.DeleteOk
+ :param callable callback: callback(pika.frame.Method) for method
Queue.DeleteOk
:raises ValueError:

"""
@@ -854,7 +850,7 @@
"""Purge all of the messages from the specified queue

:param str queue: The queue to purge
- :param callable callback: The callback to call on Queue.PurgeOk
+ :param callable callback: callback(pika.frame.Method) for method
Queue.PurgeOk
:raises ValueError:

"""
@@ -876,7 +872,7 @@
:param str exchange: The source exchange to bind from
:param str routing_key: The routing key to unbind
:param dict arguments: Custom key/value pair arguments for the binding
- :param callable callback: The callback to call on Queue.UnbindOk
+ :param callable callback: callback(pika.frame.Method) for method
Queue.UnbindOk
:raises ValueError:

"""
@@ -957,12 +953,11 @@
signature: callback(channel)

"""
- self.callbacks.add(
- self.channel_number,
- self._ON_CHANNEL_CLEANUP_CB_KEY,
- callback,
- one_shot=True,
- only_caller=self)
+ self.callbacks.add(self.channel_number,
+ self._ON_CHANNEL_CLEANUP_CB_KEY,
+ callback,
+ one_shot=True,
+ only_caller=self)

def _cleanup(self):
"""Remove all consumers and any callbacks for the channel."""
@@ -1363,18 +1358,16 @@
else:
arguments = None
LOGGER.debug('Adding on_synchronous_complete callback')
- self.callbacks.add(
- self.channel_number,
- reply,
- self._on_synchronous_complete,
- arguments=arguments)
+ self.callbacks.add(self.channel_number,
+ reply,
+ self._on_synchronous_complete,
+ arguments=arguments)
if callback is not None:
LOGGER.debug('Adding passed-in RPC response callback')
- self.callbacks.add(
- self.channel_number,
- reply,
- callback,
- arguments=arguments)
+ self.callbacks.add(self.channel_number,
+ reply,
+ callback,
+ arguments=arguments)

def _raise_if_not_open(self):
"""If channel is not in the OPEN state, raises ChannelWrongStateError
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/pika/connection.py
new/pika-1.0.1/pika/connection.py
--- old/pika-1.0.0/pika/connection.py 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/pika/connection.py 2019-04-12 19:45:56.000000000 +0200
@@ -571,7 +571,7 @@
:param pika.credentials.Credentials credentials: auth credentials
:param int channel_max: Maximum number of channels to allow
:param int frame_max: The maximum byte size for an AMQP frame
- :param int|None|callable value: Controls AMQP heartbeat timeout
negotiation
+ :param int|None|callable heartbeat: Controls AMQP heartbeat timeout
negotiation
during connection tuning. An integer value always overrides the
value
proposed by broker. Use 0 to deactivate heartbeats and None to
always
accept the broker's proposal. If a callable is given, it will be
called
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/setup.py new/pika-1.0.1/setup.py
--- old/pika-1.0.0/setup.py 2019-03-27 01:39:32.000000000 +0100
+++ new/pika-1.0.1/setup.py 2019-04-12 19:45:56.000000000 +0200
@@ -16,7 +16,7 @@

setuptools.setup(
name='pika',
- version='1.0.0',
+ version='1.0.1',
description='Pika Python AMQP Client Library',
long_description=open('README.rst').read(),
maintainer='Gavin M. Roy',
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/pika-1.0.0/tests/acceptance/twisted_adapter_tests.py
new/pika-1.0.1/tests/acceptance/twisted_adapter_tests.py
--- old/pika-1.0.0/tests/acceptance/twisted_adapter_tests.py 2019-03-27
01:39:32.000000000 +0100
+++ new/pika-1.0.1/tests/acceptance/twisted_adapter_tests.py 2019-04-12
19:45:56.000000000 +0200
@@ -24,7 +24,7 @@
from pika import spec
from pika.exceptions import (
AMQPConnectionError, ConsumerCancelled, DuplicateGetOkCallback, NackError,
- UnroutableError)
+ UnroutableError, ChannelClosedByBroker)
from pika.frame import Method


@@ -186,6 +186,14 @@
d = self.channel.basic_consume(queue="testqueue")
return self.assertFailure(d, RuntimeError)

+ def test_basic_consume_errback_on_close(self):
+ # Verify Deferreds that haven't had their callback invoked errback when
+ # the channel closes.
+ d = self.channel.basic_consume(queue="testqueue")
+ self.channel._on_channel_closed(
+ self, ChannelClosedByBroker(404, "NOT FOUND"))
+ return self.assertFailure(d, ChannelClosedByBroker)
+
@deferred(timeout=5.0)
def test_queue_delete(self):
# Verify that the consumers are cleared when a queue is deleted.


< Previous Next >
This Thread