def add_on_connection_close_callback(self):
        self.lg("Adding connection close callback", 6)
        self.m_connection.add_on_close_callback(self.on_connection_closed)
    
    # end of add_on_connection_close_callback
Stop scheduling tasks because an engine has been unregistered
dataset/ETHPy150Open GetLevvel/message-simulator/src/rabbit_message_publisher.py/RabbitMessagePublisher.add_on_connection_close_callback--crossover with--dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py/Client._stop_scheduling_tasks