From a3dc10b405eab5c35da9d55e3b5c50eccd32fbf2 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 6 Dec 2018 16:45:00 -0500 Subject: [PATCH] Fix Javadocs in the MessageGroupQueue --- .../integration/store/MessageGroupQueue.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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> 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> 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;