def testReceiveMessages(self):
    """Test Receiving messages with no status."""
    flow_obj = self.FlowSetup("FlowOrderTest")

    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)

    # Make sure the task is still on the client queue
    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)

    # Check that messages were stored correctly
    for message in messages:
      stored_message, _ = data_store.DB.Resolve(
          session_id.Add("state/request:00000001"),
          (1, message.response_id) % manager.FLOW_RESPONSE_TEMPLATE,
          token=self.token)

      stored_message = rdf_flows.GrrMessage(stored_message)
      self.assertRDFValuesEqual(stored_message, message)

    return messages
dataset/ETHPy150Open google/grr/grr/lib/front_end_test.py/GRRFEServerTest.testReceiveMessages/swapped operands of `%`