diff --git a/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessor.java b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessor.java index b9b71f311b..bd0c29cf3d 100644 --- a/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessor.java +++ b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessor.java @@ -64,7 +64,7 @@ public class GroovyScriptExecutingMessageProcessor extends AbstractScriptExecuti synchronized (this) { this.customizer.setMessage(message); if (this.scriptVariableSource != null){ - this.customizer.setResolvedScriptVariables(this.scriptVariableSource.resolveScriptVariables()); + this.customizer.setResolvedScriptVariables(this.scriptVariableSource.resolveScriptVariables(message)); } Object result = this.scriptFactory.getScriptedObject(scriptSource, null); return (result instanceof GString) ? result.toString() : result; diff --git a/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/ScriptVariableSource.java b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/ScriptVariableSource.java index cbc327d393..3864c68bce 100644 --- a/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/ScriptVariableSource.java +++ b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/ScriptVariableSource.java @@ -17,6 +17,8 @@ package org.springframework.integration.groovy; import java.util.Map; +import org.springframework.integration.Message; + /** * @author Oleg Zhurakousky @@ -24,5 +26,5 @@ import java.util.Map; */ public interface ScriptVariableSource { - Map resolveScriptVariables(); + Map resolveScriptVariables(Message message); } diff --git a/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessorTests.java b/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessorTests.java index 8641d2e2f9..3d1cd34457 100644 --- a/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessorTests.java +++ b/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptExecutingMessageProcessorTests.java @@ -74,7 +74,7 @@ public class GroovyScriptExecutingMessageProcessorTests { Object result = null; for (int i = 0; i < 5; i++) { ScriptVariableSource scriptVariableSource = new ScriptVariableSource() { - public Map resolveScriptVariables() { + public Map resolveScriptVariables(Message message) { Map map = new HashMap(); map.put("date", System.nanoTime()); return map;