Invoke this command to close the channel with RabbitMQ by sending the Channel.Close RPC command.
(self)
| 83 | self.close_connection() |
| 84 | |
| 85 | def close_channel(self): |
| 86 | """Invoke this command to close the channel with RabbitMQ by sending |
| 87 | the Channel.Close RPC command. |
| 88 | """ |
| 89 | if self.channel is not None: |
| 90 | logger.info('Closing the channel') |
| 91 | self.channel.close() |
| 92 | |
| 93 | def close_connection(self): |
| 94 | """This method closes the connection to RabbitMQ.""" |