def __init__(self, endpoint, message_handler=None):
    self.raw_message_regexp = re.compile(b'(\\d{1,8}):(.*)')
    self.message_client = BaseClient(endpoint, self.__raw_message_handler)
    self.message_handler = message_handler
    self.message_id = 0
    self.wait_response = threading.Event()
    self.response = ''
    self.isconnected = self.message_client.isconnected
    self.connect = self.message_client.connect
    self.disconnect = self.message_client.disconnect
    self.queue = Queue()
    self.main_thread = threading.Thread(target=self.worker)
    self.main_thread.setDaemon(1)
    self.main_thread.start()
def __init__(self, endpoint, message_handler=None):
    self.raw_message_regexp = re.compile(b'(\\d{1,8}):(.*)')
    self.message_client = BaseClient(endpoint, self.__raw_message_handler)
    self.message_handler = message_handler
    self.message_id = 0
    self.wait_response = threading.Event()
    self.response = 
    self.isconnected = self.message_client.isconnected
    self.connect = self.message_client.connect
    self.disconnect = self.message_client.disconnect
    self.queue = Queue()
    self.main_thread = threading.Thread(target=self.worker)
    self.main_thread.setDaemon(1)
    self.main_thread.start()