diff --git a/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java b/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java
index d69b4aa462..1471eecd76 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java
@@ -348,7 +348,8 @@ public class MessageGroupQueue extends AbstractQueue<Message<?>> implements Bloc
 
 	/**
 	 * It is assumed that the 'storeLock' is being held by the caller, otherwise
-	 * IllegalMonitorStateException may be thrown
+	 * IllegalMonitorStateException may be thrown.
+	 * @return a message or null
 	 */
 	protected Message<?> doPoll() {
 		Message<?> message = this.messageGroupStore.pollMessageFromGroup(this.groupId);
@@ -358,8 +359,9 @@ public class MessageGroupQueue extends AbstractQueue<Message<?>> implements Bloc
 
 	/**
 	 * It is assumed that the 'storeLock' is being held by the caller, otherwise
-	 * IllegalMonitorStateException may be thrown
+	 * IllegalMonitorStateException may be thrown.
 	 * @param message the message to offer.
+	 * @return true or false if message has been added to the message group.
 	 */
 	protected boolean doOffer(Message<?> message) {
 		boolean offered = false;