diff --git a/spring-integration-core/src/main/java/org/springframework/integration/handler/AbstractScriptExecutingMessageProcessor.java b/spring-integration-core/src/main/java/org/springframework/integration/handler/AbstractScriptExecutingMessageProcessor.java
index 428195296f..e51a74ea40 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/handler/AbstractScriptExecutingMessageProcessor.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/handler/AbstractScriptExecutingMessageProcessor.java
@@ -1,17 +1,14 @@
 /*
  * Copyright 2002-2010 the original author or authors.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
  */
 
 package org.springframework.integration.handler;
@@ -19,7 +16,6 @@ package org.springframework.integration.handler;
 import org.springframework.integration.Message;
 import org.springframework.integration.MessageHandlingException;
 import org.springframework.scripting.ScriptSource;
-import org.springframework.util.Assert;
 
 /**
  * Base {@link MessageProcessor} for scripting implementations to extend.
@@ -29,33 +25,29 @@ import org.springframework.util.Assert;
  */
 public abstract class AbstractScriptExecutingMessageProcessor<T> implements MessageProcessor<T> {
 
-	private final ScriptSource scriptSource;
-
-
-	/**
-	 * Create a processor for the given {@link ScriptSource}.
-	 */
-	public AbstractScriptExecutingMessageProcessor(ScriptSource scriptSource) {
-		Assert.notNull(scriptSource, "scriptSource must not be null");
-		this.scriptSource = scriptSource;
-	}
-
-
 	/**
 	 * Executes the script and returns the result.
 	 */
 	public final T processMessage(Message<?> message) {
 		try {
-			return this.executeScript(this.scriptSource, message);
-		}
-		catch (Exception e) {
+			return this.executeScript(getScriptSource(message), message);
+		} catch (Exception e) {
 			throw new MessageHandlingException(message, "failed to execute script", e);
 		}
 	}
 
 	/**
-	 * Subclasses must implement this method. In doing so, the execution context for the
-	 * script should be populated with the Message's 'payload' and 'headers' as variables. 
+	 * Subclasses must implement this method to create a script source, optionally using the message to locate or
+	 * create the script.
+	 * 
+	 * @param message the message being processed
+	 * @return a ScriptSource to use to create a script
+	 */
+	protected abstract ScriptSource getScriptSource(Message<?> message);
+
+	/**
+	 * Subclasses must implement this method. In doing so, the execution context for the script should be populated with
+	 * the Message's 'payload' and 'headers' as variables.
 	 */
 	protected abstract T executeScript(ScriptSource scriptSource, Message<?> message) throws Exception;
 
diff --git a/spring-integration-event/template.mf b/spring-integration-event/template.mf
index b9ec36fe94..55ee14dd66 100644
--- a/spring-integration-event/template.mf
+++ b/spring-integration-event/template.mf
@@ -4,9 +4,9 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.expression.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.expression.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-feed/template.mf b/spring-integration-feed/template.mf
index bb97ba3b6a..56fcfd144c 100644
--- a/spring-integration-feed/template.mf
+++ b/spring-integration-feed/template.mf
@@ -7,11 +7,11 @@ Import-Template:
  org.apache.commons.lang.*;version="[2.5.0, 3.0.0)",
  org.apache.commons.net.*;version="[2.0.0, 3.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.scheduling.*;version="[3.0.3, 4.0.0)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.scheduling.*;version="[3.0.5, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  com.sun.syndication.*;version="[1.0.0, 2.0.0)",
  javax.*;version="0",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-file/template.mf b/spring-integration-file/template.mf
index fcf52f56e4..dbefbfeedf 100644
--- a/spring-integration-file/template.mf
+++ b/spring-integration-file/template.mf
@@ -5,11 +5,11 @@ Bundle-ManifestVersion: 2
 Import-Template: 
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
- org.springframework.util.xml;version="[3.0.3, 4.0.0)",
- org.springframework.scheduling.*;version="[3.0.3, 4.0.0)",
- org.springframework.transaction.*;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.scheduling.*;version="[3.0.5, 4.0.0)",
+ org.springframework.transaction.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
+ org.springframework.util.xml;version="[3.0.5, 4.0.0)",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-ftp/template.mf b/spring-integration-ftp/template.mf
index 36e6277820..b45fc36cfe 100644
--- a/spring-integration-ftp/template.mf
+++ b/spring-integration-ftp/template.mf
@@ -7,11 +7,11 @@ Import-Template:
  org.apache.commons.lang.*;version="[2.5.0, 3.0.0)",
  org.apache.commons.net.*;version="[2.0.0, 3.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.scheduling.*;version="[3.0.3, 4.0.0)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.scheduling.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.jivesoftware.*;version="[3.1.0, 4.0.0)",
  javax.*;version="0",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-groovy/.springBeans b/spring-integration-groovy/.springBeans
index dbe284d518..211af10331 100644
--- a/spring-integration-groovy/.springBeans
+++ b/spring-integration-groovy/.springBeans
@@ -1,13 +1,13 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<beansProjectDescription>
-	<version>1</version>
-	<pluginVersion><![CDATA[2.3.3.201005160334-M1]]></pluginVersion>
-	<configSuffixes>
-		<configSuffix><![CDATA[xml]]></configSuffix>
-	</configSuffixes>
-	<enableImports><![CDATA[false]]></enableImports>
-	<configs>
-	</configs>
-	<configSets>
-	</configSets>
-</beansProjectDescription>
+<?xml version="1.0" encoding="UTF-8"?>
+<beansProjectDescription>
+	<version>1</version>
+	<pluginVersion><![CDATA[2.5.0.201008251000-M3]]></pluginVersion>
+	<configSuffixes>
+		<configSuffix><![CDATA[xml]]></configSuffix>
+	</configSuffixes>
+	<enableImports><![CDATA[false]]></enableImports>
+	<configs>
+	</configs>
+	<configSets>
+	</configSets>
+</beansProjectDescription>
diff --git a/spring-integration-groovy/pom.xml b/spring-integration-groovy/pom.xml
index 8be1f46cc4..444e7a412b 100644
--- a/spring-integration-groovy/pom.xml
+++ b/spring-integration-groovy/pom.xml
@@ -15,7 +15,7 @@
 		<dependency>
 			<groupId>org.codehaus.groovy</groupId>
 			<artifactId>groovy-all</artifactId>
-			<version>1.7.3</version>
+			<version>1.7.5</version>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.integration</groupId>
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 4d63f69270..ea447eaa7f 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
@@ -16,15 +16,11 @@
 
 package org.springframework.integration.groovy;
 
-import groovy.lang.Binding;
 import groovy.lang.GString;
-import groovy.lang.GroovyObject;
-import groovy.lang.Script;
 
 import org.springframework.integration.Message;
 import org.springframework.integration.handler.AbstractScriptExecutingMessageProcessor;
 import org.springframework.scripting.ScriptSource;
-import org.springframework.scripting.groovy.GroovyObjectCustomizer;
 import org.springframework.scripting.groovy.GroovyScriptFactory;
 import org.springframework.util.Assert;
 
@@ -39,9 +35,15 @@ public class GroovyScriptExecutingMessageProcessor extends AbstractScriptExecuti
 
 	private final MessageContextBindingCustomizer customizer = new MessageContextBindingCustomizer();
 
+	private final ScriptSource scriptSource;
 
+
+	/**
+	 * Create a processor for the given {@link ScriptSource}.
+	 */
 	public GroovyScriptExecutingMessageProcessor(ScriptSource scriptSource) {
-		super(scriptSource);
+		Assert.notNull(scriptSource, "scriptSource must not be null");
+		this.scriptSource = scriptSource;
 		this.scriptFactory = new GroovyScriptFactory(this.getClass().getSimpleName(), this.customizer);
 	}
 
@@ -55,23 +57,9 @@ public class GroovyScriptExecutingMessageProcessor extends AbstractScriptExecuti
 		}
 	}
 
-
-	private static class MessageContextBindingCustomizer implements GroovyObjectCustomizer {
-
-		private volatile Message<?> message;
-
-		public void setMessage(Message<?> message) {
-			this.message = message;
-		}
-
-		public void customize(GroovyObject goo) {
-			Assert.state(goo instanceof Script, "Expected a Script");
-			if (this.message != null) {
-				Binding binding = ((Script) goo).getBinding();
-				binding.setVariable("payload", this.message.getPayload());
-				binding.setVariable("headers", this.message.getHeaders());
-			}
-		}
+	@Override
+	protected ScriptSource getScriptSource(Message<?> message) {
+		return scriptSource;
 	}
 
 }
diff --git a/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptPayloadMessageProcessor.java b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptPayloadMessageProcessor.java
new file mode 100644
index 0000000000..22d2005605
--- /dev/null
+++ b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/GroovyScriptPayloadMessageProcessor.java
@@ -0,0 +1,67 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package org.springframework.integration.groovy;
+
+import groovy.lang.GString;
+
+import java.util.Map;
+
+import org.springframework.integration.Message;
+import org.springframework.integration.handler.AbstractScriptExecutingMessageProcessor;
+import org.springframework.scripting.ScriptSource;
+import org.springframework.scripting.groovy.GroovyScriptFactory;
+import org.springframework.scripting.support.StaticScriptSource;
+import org.springframework.util.Assert;
+
+/**
+ * @author Dave Syer
+ * @author Mark Fisher
+ * @since 2.0
+ */
+public class GroovyScriptPayloadMessageProcessor extends AbstractScriptExecutingMessageProcessor<Object> {
+
+	private final Map<String, ?> map;
+
+	public GroovyScriptPayloadMessageProcessor() {
+		this(null);
+	}
+
+	public GroovyScriptPayloadMessageProcessor(Map<String, ?> map) {
+		this.map = map;
+	}
+
+	@Override
+	protected ScriptSource getScriptSource(Message<?> message) {
+		Object payload = message.getPayload();
+		Assert.isInstanceOf(String.class, payload, "Payload must be String containing Groovy script.");
+		String className = generateScriptName(message);
+		return new StaticScriptSource((String) payload, className);
+	}
+
+	@Override
+	protected Object executeScript(ScriptSource scriptSource, Message<?> message) throws Exception {
+		// Keeping everything local prevents PermGen (class instances) leaks...
+		MessageContextBindingCustomizer bindingCustomizer = new MessageContextBindingCustomizer(this.map);
+		bindingCustomizer.setMessage(message);
+		GroovyScriptFactory scriptFactory = new GroovyScriptFactory(this.getClass().getSimpleName(), bindingCustomizer);
+		Object result = scriptFactory.getScriptedObject(scriptSource, null);
+		return (result instanceof GString) ? result.toString() : result;
+	}
+	
+	protected String generateScriptName(Message<?> message) {
+		// Don't use the same script (class) name for all invocations by default
+		return getClass().getSimpleName() + message.getHeaders().getId().toString().replaceAll("-", "");
+	}
+
+}
diff --git a/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/MessageContextBindingCustomizer.java b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/MessageContextBindingCustomizer.java
new file mode 100644
index 0000000000..8cd6c9f28f
--- /dev/null
+++ b/spring-integration-groovy/src/main/java/org/springframework/integration/groovy/MessageContextBindingCustomizer.java
@@ -0,0 +1,87 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package org.springframework.integration.groovy;
+
+import groovy.lang.Binding;
+import groovy.lang.GroovyObject;
+import groovy.lang.Script;
+
+import java.util.Map;
+
+import org.springframework.integration.Message;
+import org.springframework.scripting.groovy.GroovyObjectCustomizer;
+import org.springframework.util.Assert;
+
+/**
+ * A groovy object customizer used internally by the groovy message processors. Not public because the customizer is not
+ * the best API for groovy context binding, but it's what we have in Spring right now.
+ * 
+ * @since 2.0
+ * @author Dave Syer
+ * 
+ */
+class MessageContextBindingCustomizer implements GroovyObjectCustomizer {
+
+	private volatile Message<?> message;
+	private final GroovyObjectCustomizer customizer;
+
+	public MessageContextBindingCustomizer() {
+		this((GroovyObjectCustomizer) null);
+	}
+
+	public MessageContextBindingCustomizer(Map<String, ?> context) {
+		this(new MapContextBindingCustomizer(context));
+	}
+
+	public MessageContextBindingCustomizer(GroovyObjectCustomizer customizer) {
+		this.customizer = customizer;
+	}
+
+	public void setMessage(Message<?> message) {
+		this.message = message;
+	}
+
+	public void customize(GroovyObject goo) {
+		Assert.state(goo instanceof Script, "Expected a Script");
+		if (customizer != null) {
+			customizer.customize(goo);
+		}
+		if (this.message != null) {
+			Binding binding = ((Script) goo).getBinding();
+			binding.setVariable("payload", this.message.getPayload());
+			binding.setVariable("headers", this.message.getHeaders());
+		}
+	}
+
+	private static class MapContextBindingCustomizer implements GroovyObjectCustomizer {
+
+		private final Map<String, ?> map;
+
+		public MapContextBindingCustomizer(Map<String, ?> map) {
+			this.map = map;
+		}
+
+		public void customize(GroovyObject goo) {
+			Assert.state(goo instanceof Script, "Expected a Script");
+			if (this.map != null) {
+				Binding binding = ((Script) goo).getBinding();
+				for (String key : map.keySet()) {
+					binding.setVariable(key, map.get(key));
+				}
+			}
+
+		}
+
+	}
+}
\ No newline at end of file
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 f20068f233..fcea598c38 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
@@ -22,7 +22,9 @@ import static org.junit.Assert.assertFalse;
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.concurrent.atomic.AtomicInteger;
 
+import org.junit.Rule;
 import org.junit.Test;
 import org.springframework.core.io.AbstractResource;
 import org.springframework.integration.Message;
@@ -31,6 +33,7 @@ import org.springframework.integration.handler.MessageProcessor;
 import org.springframework.integration.support.MessageBuilder;
 import org.springframework.scripting.ScriptSource;
 import org.springframework.scripting.support.ResourceScriptSource;
+import org.springframework.test.annotation.Repeat;
 
 /**
  * @author Mark Fisher
@@ -40,15 +43,22 @@ import org.springframework.scripting.support.ResourceScriptSource;
  */
 public class GroovyScriptExecutingMessageProcessorTests {
 
+	@Rule
+	public RepeatProcessor repeater = new RepeatProcessor(4);
+
+	private AtomicInteger countHolder = new AtomicInteger();
+
 	@Test
+	@Repeat(20)
 	public void testSimpleExecution() throws Exception {
+		int count = countHolder.getAndIncrement();
 		String script = "return \"payload is $payload, header is $headers.testHeader\"";
-		Message<?> message = MessageBuilder.withPayload("foo").setHeader("testHeader", "bar").build();
+		Message<?> message = MessageBuilder.withPayload("foo").setHeader("testHeader", "bar"+count).build();
 		TestResource resource = new TestResource(script, "simpleTest");
 		ScriptSource scriptSource = new ResourceScriptSource(resource);
 		MessageProcessor<Object> processor = new GroovyScriptExecutingMessageProcessor(scriptSource);
 		Object result = processor.processMessage(message);
-		assertEquals("payload is foo, header is bar", result.toString());
+		assertEquals("payload is foo, header is bar"+count, result.toString());
 	}
 
 	@Test
diff --git a/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptPayloadMessageProcessorTests.java b/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptPayloadMessageProcessorTests.java
new file mode 100644
index 0000000000..d59a5f14bf
--- /dev/null
+++ b/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/GroovyScriptPayloadMessageProcessorTests.java
@@ -0,0 +1,70 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package org.springframework.integration.groovy;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.Collections;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import org.junit.Rule;
+import org.junit.Test;
+import org.springframework.integration.Message;
+import org.springframework.integration.handler.MessageProcessor;
+import org.springframework.integration.support.MessageBuilder;
+import org.springframework.test.annotation.Repeat;
+
+/**
+ * @author Dave Syer
+ * @since 2.0
+ */
+public class GroovyScriptPayloadMessageProcessorTests {
+
+	@Rule
+	public RepeatProcessor repeater = new RepeatProcessor(4);
+
+	private AtomicInteger countHolder = new AtomicInteger();
+
+	private GroovyScriptPayloadMessageProcessor processor = new GroovyScriptPayloadMessageProcessor();
+
+	@Test
+	@Repeat(20)
+	public void testSimpleExecution() throws Exception {
+		int count = countHolder.getAndIncrement();
+		Message<?> message = MessageBuilder.withPayload("headers.foo" + count).setHeader("foo" + count, "bar").build();
+		Object result = processor.processMessage(message);
+		assertEquals("bar", result.toString());
+	}
+
+	@Test
+	public void testDoubleExecutionWithNewScript() throws Exception {
+		Message<?> message = MessageBuilder.withPayload("headers.foo").setHeader("foo", "bar").build();
+		Object result = processor.processMessage(message);
+		assertEquals("bar", result.toString());
+		message = MessageBuilder.withPayload("headers.bar").setHeader("bar", "spam").build();
+		result = processor.processMessage(message);
+		assertEquals("spam", result.toString());
+	}
+
+	@Test
+	public void testSimpleExecutionWithContext() throws Exception {
+		Message<?> message = MessageBuilder.withPayload("\"spam is $spam foo is $headers.foo\"")
+				.setHeader("foo", "bar").build();
+		MessageProcessor<Object> processor = new GroovyScriptPayloadMessageProcessor(Collections.singletonMap("spam",
+				"bucket"));
+		Object result = processor.processMessage(message);
+		assertEquals("spam is bucket foo is bar", result.toString());
+	}
+
+}
diff --git a/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/RepeatProcessor.java b/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/RepeatProcessor.java
new file mode 100644
index 0000000000..d2c65fb01d
--- /dev/null
+++ b/spring-integration-groovy/src/test/java/org/springframework/integration/groovy/RepeatProcessor.java
@@ -0,0 +1,96 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package org.springframework.integration.groovy;
+
+import static org.junit.Assert.assertTrue;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+import org.junit.rules.MethodRule;
+import org.junit.runners.model.FrameworkMethod;
+import org.junit.runners.model.Statement;
+import org.springframework.core.annotation.AnnotationUtils;
+import org.springframework.test.annotation.Repeat;
+
+/**
+ * A method rule that looks at Spring repeat annotations on methods and executes the test multiple times (without
+ * re-initializing the test case).
+ * 
+ * @author Dave Syer
+ * @since 2.0
+ * 
+ */
+public class RepeatProcessor implements MethodRule {
+
+	private final int concurrency;
+
+	public RepeatProcessor(int concurrency) {
+		this.concurrency = concurrency < 0 ? 0 : concurrency;
+	}
+
+	public Statement apply(final Statement base, FrameworkMethod method, Object target) {
+		Repeat repeat = AnnotationUtils.findAnnotation(method.getMethod(), Repeat.class);
+		if (repeat == null) {
+			return base;
+		}
+		final int repeats = repeat.value();
+		if (concurrency <= 0) {
+			return new Statement() {
+				@Override
+				public void evaluate() throws Throwable {
+					for (int i = 0; i < repeats; i++) {
+						try {
+							base.evaluate();
+						} catch (Throwable t) {
+							throw new IllegalStateException("Failed on iteration: " + i, t);
+						}
+					}
+				}
+			};
+		}
+		return new Statement() {
+			@Override
+			public void evaluate() throws Throwable {
+				List<Future<Boolean>> results = new ArrayList<Future<Boolean>>();
+				ExecutorService executor = Executors.newFixedThreadPool(concurrency);
+				try {
+					for (int i = 0; i < repeats; i++) {
+						final int count = i;
+						results.add(executor.submit(new Callable<Boolean>() {
+							public Boolean call() {
+								try {
+									base.evaluate();
+								} catch (Throwable t) {
+									throw new IllegalStateException("Failed on iteration: " + count, t);
+								}
+								return true;
+							}
+						}));
+					}
+					for (Future<Boolean> future : results) {
+						assertTrue("Null result from completer", future.get(10, TimeUnit.SECONDS));
+					}
+				} finally {
+					executor.shutdownNow();
+				}
+			}
+		};
+	}
+}
\ No newline at end of file
diff --git a/spring-integration-groovy/template.mf b/spring-integration-groovy/template.mf
index 752538a16e..5ad3f75e74 100644
--- a/spring-integration-groovy/template.mf
+++ b/spring-integration-groovy/template.mf
@@ -5,6 +5,6 @@ Bundle-ManifestVersion: 2
 Import-Template: 
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.*;version="[3.0.3, 4.0.0)",
+ org.springframework.*;version="[3.0.5, 4.0.0)",
  groovy.*;version="[1.7.3, 2.0.0)",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-http/template.mf b/spring-integration-http/template.mf
index 1a53c82590..c64c2e8c6c 100644
--- a/spring-integration-http/template.mf
+++ b/spring-integration-http/template.mf
@@ -4,14 +4,14 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.validation.*;version="[3.0.3, 4.0.0)",
- org.springframework.expression.*;version="[3.0.3, 4.0.0)",
- org.springframework.context.*;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.http.*;version="[3.0.3, 4.0.0)",
- org.springframework.util.*;version="[3.0.3, 4.0.0)",
- org.springframework.web.*;version="[3.0.3, 4.0.0)";resolution:=optional,
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context.*;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.expression.*;version="[3.0.5, 4.0.0)",
+ org.springframework.http.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util.*;version="[3.0.5, 4.0.0)",
+ org.springframework.validation.*;version="[3.0.5, 4.0.0)",
+ org.springframework.web.*;version="[3.0.5, 4.0.0)";resolution:=optional,
  org.apache.commons.httpclient.*;version="[3.1.0, 4.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  javax.servlet.*;version="[2.4.0, 3.0.0)";resolution:=optional,
diff --git a/spring-integration-httpinvoker/template.mf b/spring-integration-httpinvoker/template.mf
index 61119aea13..aa8ac94705 100644
--- a/spring-integration-httpinvoker/template.mf
+++ b/spring-integration-httpinvoker/template.mf
@@ -4,12 +4,12 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.remoting.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
- org.springframework.web;version="[3.0.3, 4.0.0)";resolution:=optional,
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.remoting.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
+ org.springframework.web;version="[3.0.5, 4.0.0)";resolution:=optional,
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  javax.servlet.*;version="[2.4.0, 3.0.0)";resolution:=optional,
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-jms/template.mf b/spring-integration-jms/template.mf
index 7dd04c178c..5a7163e8f1 100644
--- a/spring-integration-jms/template.mf
+++ b/spring-integration-jms/template.mf
@@ -4,12 +4,12 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.jms.*;version="[3.0.3, 4.0.0)",
- org.springframework.transaction.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.jms.*;version="[3.0.5, 4.0.0)",
+ org.springframework.transaction.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  javax.jms;version="[1.1.0, 2.0.0)";resolution:=optional,
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-jmx/template.mf b/spring-integration-jmx/template.mf
index 6e4676f90e..195bf6b2ce 100644
--- a/spring-integration-jmx/template.mf
+++ b/spring-integration-jmx/template.mf
@@ -4,7 +4,7 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.*;version="[3.0.3, 4.0.0)",
+ org.springframework.*;version="[3.0.5, 4.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.aopalliance.*;version="[1.0.0, 2.0.0)",
  javax.management.*;version="0",
diff --git a/spring-integration-mail/template.mf b/spring-integration-mail/template.mf
index 748a52e9d3..5ccbc0c745 100644
--- a/spring-integration-mail/template.mf
+++ b/spring-integration-mail/template.mf
@@ -4,11 +4,11 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.mail.*;version="[3.0.3, 4.0.0)",
- org.springframework.util.*;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.mail.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util.*;version="[3.0.5, 4.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  javax.mail.*;version="[1.4.0, 2.0.0)",
  com.sun.mail.imap.*;version="[1.4.0, 2.0.0)";resolution:=optional,
diff --git a/spring-integration-rmi/template.mf b/spring-integration-rmi/template.mf
index 4198b3d42f..7beef23402 100644
--- a/spring-integration-rmi/template.mf
+++ b/spring-integration-rmi/template.mf
@@ -4,10 +4,10 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.remoting.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.remoting.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-security/template.mf b/spring-integration-security/template.mf
index c32e6d8e8d..27ec2b9bfb 100644
--- a/spring-integration-security/template.mf
+++ b/spring-integration-security/template.mf
@@ -5,10 +5,10 @@ Bundle-ManifestVersion: 2
 Import-Template: 
  org.aopalliance.*;version="[1.0.0, 2.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
- org.springframework.aop.*;version="[3.0.3, 4.0.0)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.core;version="[3.0.3, 4.0.0)",
- org.springframework.util.*;version="[3.0.3, 4.0.0)",
+ org.springframework.aop.*;version="[3.0.5, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.core;version="[3.0.5, 4.0.0)",
+ org.springframework.util.*;version="[3.0.5, 4.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
  org.springframework.security.*;version="[3.0.3, 4.0.0)",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-sftp/template.mf b/spring-integration-sftp/template.mf
index 7b19d578bc..15b449738b 100644
--- a/spring-integration-sftp/template.mf
+++ b/spring-integration-sftp/template.mf
@@ -7,11 +7,11 @@ Import-Template:
  org.apache.commons.lang.*;version="[2.5.0, 3.0.0)",
  org.apache.commons.io.*;version="[1.4.0, 2.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
- org.springframework.scheduling.*;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.scheduling.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.jivesoftware.*;version="[3.1.0, 4.0.0)",
  com.jcraft.jsch.*;version="[0.1.41,0.1.41]",
  javax.*;version="0",
diff --git a/spring-integration-stream/template.mf b/spring-integration-stream/template.mf
index dce5a02ccb..78e01d7943 100644
--- a/spring-integration-stream/template.mf
+++ b/spring-integration-stream/template.mf
@@ -4,7 +4,7 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-test/template.mf b/spring-integration-test/template.mf
index 4ed55683e8..439841a7c1 100644
--- a/spring-integration-test/template.mf
+++ b/spring-integration-test/template.mf
@@ -4,7 +4,7 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.apache.tools.ant.*;version="[1.7.0, 2.0.0)",
- org.springframework.*;version="[3.0.3, 4.0.0)",
+ org.springframework.*;version="[3.0.5, 4.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
  junit.framework.*;version="[4.6.0, 4.7.0)",
  org.junit.*;version="[4.6.0, 4.7.0)",
diff --git a/spring-integration-twitter/template.mf b/spring-integration-twitter/template.mf
index cc2e575d79..3b2b10b198 100644
--- a/spring-integration-twitter/template.mf
+++ b/spring-integration-twitter/template.mf
@@ -6,12 +6,12 @@ Import-Template:
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.apache.commons.lang.*;version="[2.5.0, 3.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.jivesoftware.*;version="[3.1.0, 4.0.0)",
- org.apache.commons.io.*;version="[1.4,3.0)",
- twitter4j.*;version="[2.1.0,2.2.0]",
+ org.apache.commons.io.*;version="[1.4, 3.0)",
+ twitter4j.*;version="[2.1.0, 2.3.0)",
  javax.*;version="0",
  org.w3c.dom.*;version="0"
diff --git a/spring-integration-ws/template.mf b/spring-integration-ws/template.mf
index eed0b41f62..480f0cc768 100644
--- a/spring-integration-ws/template.mf
+++ b/spring-integration-ws/template.mf
@@ -4,14 +4,14 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.expression;version="[3.0.3, 4.0.0)",
- org.springframework.scheduling.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
- org.springframework.oxm;version="[1.5.8.A, 3.1.0)",
- org.springframework.ws.*;version="[1.5.8.A, 2.0.0)",
- org.springframework.xml.*;version="[1.5.8.A, 2.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.expression;version="[3.0.5, 4.0.0)",
+ org.springframework.scheduling.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
+ org.springframework.oxm;version="[1.5.9, 3.1.0)",
+ org.springframework.ws.*;version="[1.5.9, 2.0.0)",
+ org.springframework.xml.*;version="[1.5.9, 2.0.0)",
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.w3c.dom.*;version="0",
  javax.xml.*;version="0"
diff --git a/spring-integration-xml/template.mf b/spring-integration-xml/template.mf
index 43a99e537f..9fb68206e2 100644
--- a/spring-integration-xml/template.mf
+++ b/spring-integration-xml/template.mf
@@ -4,14 +4,14 @@ Bundle-Vendor: SpringSource
 Bundle-ManifestVersion: 2
 Import-Template: 
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util.*;version="[3.0.3, 4.0.0)",
- org.springframework.expression.*;version="[3.0.3, 4.0.0)",
- org.springframework.context.expression.*;version="[3.0.3, 4.0.0)",
- org.springframework.oxm;version="[1.5.7.A, 2.0.0)";resolution:=optional,
- org.springframework.xml.*;version="[1.5.7.A, 2.0.0)",
- org.apache.commons.logging.*;version="[1.0,2.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context.expression.*;version="[3.0.5, 4.0.0)",
+ org.springframework.expression.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util.*;version="[3.0.5, 4.0.0)",
+ org.springframework.oxm;version="[1.5.9, 3.1.0)";resolution:=optional,
+ org.springframework.xml.*;version="[1.5.9, 2.0.0)",
+ org.apache.commons.logging.*;version="[1.0, 2.0)",
  org.w3c.dom.*;version="0",
  org.xml.sax.*;version="0",
  javax.xml.*;version="0"
diff --git a/spring-integration-xmpp/template.mf b/spring-integration-xmpp/template.mf
index 90a4008667..37b9bad352 100644
--- a/spring-integration-xmpp/template.mf
+++ b/spring-integration-xmpp/template.mf
@@ -6,10 +6,10 @@ Import-Template:
  org.apache.commons.logging;version="[1.1.1, 2.0.0)",
  org.apache.commons.lang.*;version="[2.5.0, 3.0.0)",
  org.springframework.integration.*;version="[2.0.0, 2.0.1)",
- org.springframework.beans.*;version="[3.0.3, 4.0.0)",
- org.springframework.context;version="[3.0.3, 4.0.0)",
- org.springframework.core.*;version="[3.0.3, 4.0.0)",
- org.springframework.util;version="[3.0.3, 4.0.0)",
+ org.springframework.beans.*;version="[3.0.5, 4.0.0)",
+ org.springframework.context;version="[3.0.5, 4.0.0)",
+ org.springframework.core.*;version="[3.0.5, 4.0.0)",
+ org.springframework.util;version="[3.0.5, 4.0.0)",
  org.jivesoftware.*;version="[3.1.0, 4.0.0)",
  javax.*;version="0",
  org.w3c.dom.*;version="0"