yudaike/openSUSE-release-tools
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

PubSubConsumer: Fix cancel callbacks

Browse Source
This commit is contained in:
Stephan Kulow 2019-05-02 11:37:57 +02:00
parent 22ff335e45
commit fefa1adaf7
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
PubSubConsumer.py
View File

@ -255,18 +255,27 @@ class PubSubConsumer(object):
self.logger.info('Received message # %s: %s %s', self.logger.info('Received message # %s: %s %s',
basic_deliver.delivery_tag, basic_deliver.routing_key, body) basic_deliver.delivery_tag, basic_deliver.routing_key, body)
def on_cancelok(self, unused_frame): def on_cancelok(self, _unused_frame, userdata):
"""This method is invoked by pika when RabbitMQ acknowledges the """This method is invoked by pika when RabbitMQ acknowledges the
cancellation of a consumer. At this point we will close the channel. cancellation of a consumer. At this point we will close the channel.
This will invoke the on_channel_closed method once the channel has been This will invoke the on_channel_closed method once the channel has been
closed, which will in-turn close the connection. closed, which will in-turn close the connection.
:param pika.frame.Method _unused_frame: The Basic.CancelOk frame
:param pika.frame.Method unused_frame: The Basic.CancelOk frame :param str|unicode userdata: Extra user data (consumer tag)
""" """
self.logger.debug('RabbitMQ acknowledged the cancellation of the consumer') self._consuming = False
self.logger.debug(
'RabbitMQ acknowledged the cancellation of the consumer: %s',
userdata)
self.close_channel() self.close_channel()
def close_channel(self):
"""Call to close the channel with RabbitMQ cleanly by issuing the
Channel.Close RPC command.
"""
self.logger.debug('Closing the channel')
self._channel.close()
def stop_consuming(self): def stop_consuming(self):
"""Tell RabbitMQ that you would like to stop consuming by sending the """Tell RabbitMQ that you would like to stop consuming by sending the
Basic.Cancel RPC command. Basic.Cancel RPC command.
@ -308,14 +317,6 @@ class PubSubConsumer(object):
else: else:
self.start_consuming() self.start_consuming()
def close_channel(self):
"""Call to close the channel with RabbitMQ cleanly by issuing the
Channel.Close RPC command.
"""
self.logger.debug('Closing the channel')
self._channel.close()
def open_channel(self): def open_channel(self):
"""Open a new channel with RabbitMQ by issuing the Channel.Open RPC """Open a new channel with RabbitMQ by issuing the Channel.Open RPC
command. When RabbitMQ responds that the channel is open, the command. When RabbitMQ responds that the channel is open, the