Change in ScriptService#executable parameters

Due to this change elastic/elasticsearch#10116 we need to update river plugin starting 1.6.0. Was a breaking change. Closes #95.
elastic · Mar 31, 2015 · 361b613 · 361b613
1 parent 1df982b
commit 361b613
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/main/java/org/elasticsearch/river/rabbitmq/RabbitmqRiver.java b/src/main/java/org/elasticsearch/river/rabbitmq/RabbitmqRiver.java
@@ -39,6 +39,7 @@
 import org.elasticsearch.river.RiverName;
 import org.elasticsearch.river.RiverSettings;
 import org.elasticsearch.script.ExecutableScript;
+import org.elasticsearch.script.ScriptContext;
 import org.elasticsearch.script.ScriptService;
 
 import java.io.BufferedReader;
@@ -230,7 +231,7 @@ public RabbitmqRiver(RiverName riverName, RiverSettings settings, Client client,
                     scriptParams = Maps.newHashMap();
                 }
                 bulkScript = scriptService.executable(scriptLang, scriptSettings.get("script").toString(),
-                        ScriptService.ScriptType.INLINE, scriptParams);
+                        ScriptService.ScriptType.INLINE, ScriptContext.UPDATE, scriptParams);
             } else {
                 bulkScript = null;
             }
@@ -252,7 +253,7 @@ public RabbitmqRiver(RiverName riverName, RiverSettings settings, Client client,
                     scriptParams = Maps.newHashMap();
                 }
                 script = scriptService.executable(scriptLang, scriptSettings.get("script").toString(),
-                        ScriptService.ScriptType.INLINE, scriptParams);
+                        ScriptService.ScriptType.INLINE, ScriptContext.UPDATE, scriptParams);
             } else {
                 script = null;
             }