'Handle client messages.'

def HandleMessage(self, message):

    crash_details = rdf_client.ClientCrash(client_id=self.client_id, session_id=message.session_id, crash_message='Client    killed    during    transaction', timestamp=rdfvalue.RDFDatetime.Now())
    msg = rdf_flows.GrrMessage(payload=crash_details, source=self.client_id, auth_state=rdf_flows.GrrMessage.AuthorizationState.AUTHENTICATED)
    self.flow_id = message.session_id
    events.Events.PublishEvent('ClientCrash', msg, token=self.token)
