def __init__(self, connection, **kwargs):
        threading.Thread.__init__(self, **kwargs)
        self.setDaemon(True)
        self.connection = connection
        try:
            connection.settimeout(None)  # No timeout
        except:
            pass