'Test Receiving messages with no status.'

def testReceiveMessages(self):

    flow_obj = self.FlowSetup(flow_test_lib.FlowOrderTest.__name__)
    session_id = flow_obj.session_id
    messages = [rdf_flows.GrrMessage(request_id=1, response_id=i, session_id=session_id, payload=rdfvalue.RDFInteger(i)) for i in range(1, 10)]
    self.server.ReceiveMessages(self.client_id, messages)
    manager = queue_manager.QueueManager(token=self.token)
    tasks_on_client_queue = manager.Query(self.client_id, 100)
    self.assertEqual(len(tasks_on_client_queue), 1)
    stored_messages = data_store.DB.ReadResponsesForRequestId(session_id, 1, token=self.token)
    self.assertEqual(len(stored_messages), len(messages))
    stored_messages.sort(key=(lambda m: m.response_id))
    for (stored_message, message) in zip(stored_messages, messages):
        self.assertRDFValuesEqual(stored_message, message)
