close_connection.py

import sys
from .my_logging import logging

def on_timeout(the_connection):

    def close_connection():
        nonlocal the_connection
        # global connection
        logging.info('Waiting for messages...')
        the_connection.close()
        #logging.info('Exiting.')
        #sys.exit(0)
        #return

    return close_connection