Skip to content

Commit a3dc10b

Browse files
committed
Fix Javadocs in the MessageGroupQueue
1 parent 1502485 commit a3dc10b

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -348,7 +348,8 @@ protected Collection<Message<?>> getMessages() {
348348

349349
/**
350350
* It is assumed that the 'storeLock' is being held by the caller, otherwise
351-
* IllegalMonitorStateException may be thrown
351+
* IllegalMonitorStateException may be thrown.
352+
* @return a message or null
352353
*/
353354
protected Message<?> doPoll() {
354355
Message<?> message = this.messageGroupStore.pollMessageFromGroup(this.groupId);
@@ -358,8 +359,9 @@ protected Message<?> doPoll() {
358359

359360
/**
360361
* It is assumed that the 'storeLock' is being held by the caller, otherwise
361-
* IllegalMonitorStateException may be thrown
362+
* IllegalMonitorStateException may be thrown.
362363
* @param message the message to offer.
364+
* @return true or false if message has been added to the message group.
363365
*/
364366
protected boolean doOffer(Message<?> message) {
365367
boolean offered = false;

0 commit comments

Comments
 (0)