diff --git a/java/java-analysis-impl/src/com/intellij/codeInspection/StreamApiMigrationInspection.java b/java/java-analysis-impl/src/com/intellij/codeInspection/StreamApiMigrationInspection.java
index a75e190da3d3..ca6fbba53454 100644
--- a/java/java-analysis-impl/src/com/intellij/codeInspection/StreamApiMigrationInspection.java
+++ b/java/java-analysis-impl/src/com/intellij/codeInspection/StreamApiMigrationInspection.java
@@ -719,7 +719,7 @@ public class StreamApiMigrationInspection extends BaseJavaBatchLocalInspectionTo
         foreachStatement.delete();
         return;
       }
-      final String qualifierText = qualifierExpression != null ? qualifierExpression.getText() : "this";
+      final String qualifierText = qualifierExpression != null ? qualifierExpression.getText() + "." : "";
 
       JavaCodeStyleManager codeStyleManager = JavaCodeStyleManager.getInstance(project);
       final SuggestedNameInfo suggestedNameInfo = codeStyleManager
@@ -727,7 +727,7 @@ public class StreamApiMigrationInspection extends BaseJavaBatchLocalInspectionTo
       String varName = codeStyleManager.suggestUniqueVariableName(suggestedNameInfo, qualifierExpression, false).names[0];
 
       PsiExpression forEachBody =
-        elementFactory.createExpressionFromText(qualifierText + ".add(" + varName + ")", qualifierExpression);
+        elementFactory.createExpressionFromText(qualifierText + "add(" + varName + ")", qualifierExpression);
       final String callText =
         builder.append(".forEach(").append(varName).append("->").append(forEachBody.getText()).append(");").toString();
       PsiElement result = foreachStatement.replace(elementFactory.createStatementFromText(callText, foreachStatement));