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

Fix nullability issue in queuechannel (#3012)

Browse Source 
* Added inherited @Nullable to QueueChannel.doReceive

* Minor refactoring
This commit is contained in:
Denis Kilchichakov
2019-07-29 23:27:16 +03:00
committed by Gary Russell
parent 91eb3655aa
commit ef1d7be020
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-integration-core/src/main/java/org/springframework/integration/channel/QueueChannel.java
View File

@@ -110,6 +110,7 @@ public class QueueChannel extends AbstractPollableChannel implements QueueChanne
}
@Override
@Nullable
protected Message<?> doReceive(long timeout) {
try {
if (timeout > 0) {
@@ -166,7 +167,7 @@ public class QueueChannel extends AbstractPollableChannel implements QueueChanne
((BlockingQueue<Message<?>>) this.queue).drainTo(clearedMessages);
}
else {
Message<?> message = null;
Message<?> message;
while ((message = this.queue.poll()) != null) {
clearedMessages.add(message);
}