Method stop

celery/backends/rpc.py:122–126

(self)

        logger.info('RPC result consumer: reconnected successfully.')

    def stop(self):
        try:
            self._consumer.cancel()
        finally:
            self._connection.close()

    def on_after_fork(self):
        self._consumer = None