

def _handle_client_message(self, message):
    correlation_id = message.get_correlation_id()
    if self.has_flags(LISTENER_FLAG):
        if (correlation_id not in self._event_handlers):
            self.logger.warn('Got event message with unknown correlation id: %s', message)
            return
        invocation = self._event_handlers[correlation_id]
        self._handle_event(invocation, message)
        return
    if (correlation_id not in self._pending):
        self.logger.warn('Got message with unknown correlation id: %s', message)
        return
    invocation = self._pending.pop(correlation_id)
    if (message.get_message_type() == EXCEPTION_MESSAGE_TYPE):
        error = create_exception(ErrorCodec(message))
        return self._handle_exception(invocation, error)
    invocation.set_response(message)

dataset/ETHPy150Open hazelcast/hazelcast-python-client/hazelcast/invocation.py InvocationService._handle_client_message/VarMisuse@21/30 `message`->`self`