diff --git a/plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java b/plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java
index 6b9a27632e8..b2bbad33e73 100644
--- a/plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java
+++ b/plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java
@@ -226,7 +226,7 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
     @Override public void close() {
         logger.info("closing twitter stream river");
         if (stream != null) {
-            stream.cleanup();
+            stream.cleanUp();
             stream.shutdown();
         }
     }