diff --git a/build.gradle b/build.gradle
index a9bcdf43..2c0785fe 100644
--- a/build.gradle
+++ b/build.gradle
@@ -199,8 +199,8 @@ subprojects { subproject ->
 			postgresVersion = '9.1-901-1.jdbc4'
 			subethasmtpVersion = '1.2'
 			slf4jVersion = '1.7.11'
-			springIntegrationVersion = '4.2.0.RC1'
-			springIntegrationDslVersion = '1.1.0.BUILD-SNAPSHOT'
+			springIntegrationVersion = '4.2.0.RELEASE'
+			springIntegrationDslVersion = '1.1.0.M2'
 			springVersion = '4.2.0.RELEASE'
 			springSecurityVersion = '4.0.2.RELEASE'
 			springWebFlowVersion = '2.3.3.RELEASE'
diff --git a/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/lambda/Application.java b/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/lambda/Application.java
index 2858ca23..b19e6ae4 100644
--- a/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/lambda/Application.java
+++ b/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/lambda/Application.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2014 the original author or authors.
+ * Copyright 2014-2015 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.
@@ -118,7 +118,7 @@ public class Application {
 										.stream()
 										.map(message -> (Drink) message.getPayload())
 										.collect(Collectors.toList())))
-						.correlationStrategy(m -> ((Drink) m.getPayload()).getOrderNumber()), null)
+						.correlationStrategy(m -> ((Drink) m.getPayload()).getOrderNumber()))
 				.handle(CharacterStreamWritingMessageHandler.stdout());
 	}