diff --git a/build.gradle b/build.gradle
index 7d642f1a5c..3d203d0fd6 100644
--- a/build.gradle
+++ b/build.gradle
@@ -104,7 +104,7 @@ subprojects { subproject ->
 		springGemfireVersion = '1.3.4.RELEASE'
 		springSecurityVersion = '3.2.3.RELEASE'
 		springSocialTwitterVersion = '1.1.0.RELEASE'
-		springRetryVersion = '1.0.3.RELEASE'
+		springRetryVersion = '1.1.0.RELEASE'
 		springVersion = project.hasProperty('springVersion') ? project.springVersion : '4.0.3.RELEASE'
 		springWsVersion = '2.1.4.RELEASE'
 		xmlUnitVersion = '1.5'
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java b/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java
index 041a5de88b..f287e03394 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java
@@ -44,6 +44,7 @@ public class MessagingTemplate extends GenericMessagingTemplate {
 
 	/**
 	 * Create a MessagingTemplate with the given default channel.
+	 * @param defaultChannel the default {@link MessageChannel} for {@code send} operations
 	 */
 	public MessagingTemplate(MessageChannel defaultChannel) {
 		this.setDefaultChannel(defaultChannel);
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/handler/advice/RequestHandlerRetryAdvice.java b/spring-integration-core/src/main/java/org/springframework/integration/handler/advice/RequestHandlerRetryAdvice.java
index 68e1258725..5e2e80ce68 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/handler/advice/RequestHandlerRetryAdvice.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/handler/advice/RequestHandlerRetryAdvice.java
@@ -49,6 +49,7 @@ public class RequestHandlerRetryAdvice extends AbstractRequestHandlerAdvice
 	// Stateless unless a state generator is provided
 	private volatile RetryStateGenerator retryStateGenerator =
 			new RetryStateGenerator() {
+				@Override
 				public RetryState determineRetryState(Message<?> message) {
 					return null;
 				}
@@ -81,7 +82,8 @@ public class RequestHandlerRetryAdvice extends AbstractRequestHandlerAdvice
 		messageHolder.set(message);
 
 		try {
-			return retryTemplate.execute(new RetryCallback<Object>() {
+			return retryTemplate.execute(new RetryCallback<Object, Exception>() {
+				@Override
 				public Object doWithRetry(RetryContext context) throws Exception {
 					return callback.cloneAndExecute();
 				}
@@ -102,15 +104,18 @@ public class RequestHandlerRetryAdvice extends AbstractRequestHandlerAdvice
 		}
 	}
 
-	public <T> boolean open(RetryContext context, RetryCallback<T> callback) {
+	@Override
+	public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
 		context.setAttribute("message", messageHolder.get());
 		return true;
 	}
 
-	public <T> void close(RetryContext context, RetryCallback<T> callback, Throwable throwable) {
+	@Override
+	public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
 	}
 
-	public <T> void onError(RetryContext context, RetryCallback<T> callback, Throwable throwable) {
+	@Override
+	public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
 	}
 
 }