Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Javadocs in the MessageGroupQueue

Browse Source
This commit is contained in:
Artem Bilan
2018-12-06 16:45:00 -05:00
parent 15024858d4
commit a3dc10b405
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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;