'Push given message to the state queue.'

def PushToStateQueue(self, manager, message, **kw):

    message.auth_state = rdf_flows.GrrMessage.AuthorizationState.AUTHENTICATED
    for (k, v) in kw.items():
        setattr(message, k, v)
    if (message.request_id == 0):
        if (message.type == rdf_flows.GrrMessage.Type.MESSAGE):
            message.source = self.client_id
            message.auth_state = 'AUTHENTICATED'
            session_id = message.session_id
            if session_id:
                logging.info('Running    well    known    flow:    %s', session_id)
                self.well_known_flows[session_id.FlowName()].ProcessMessage(message)
        return
    manager.QueueResponse(message)
