diff --git a/spring-integration-core/src/main/java/org/springframework/integration/message/RetrievalBlockingMessageStore.java b/spring-integration-core/src/main/java/org/springframework/integration/message/RetrievalBlockingMessageStore.java
index a0b7099378..79265317d7 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/message/RetrievalBlockingMessageStore.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/message/RetrievalBlockingMessageStore.java
@@ -100,7 +100,7 @@ public class RetrievalBlockingMessageStore extends SimpleMessageStore implements
 			if (holder != null) {
 				message = holder.getMessage();
 				if (message != null && shouldRemove) {
-					super.remove(key);
+					return super.remove(key);
 				}
 			}
 		}