Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #423

This commit is contained in:
Clebert Suconic 2016-03-17 13:53:15 -04:00
parent ab98eb9620 7653d17e6a
commit 57c1c338ea
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java
View File

@ -1089,7 +1089,7 @@ public class LargeMessageControllerImpl implements LargeMessageController {
}
int sizeToAdd = currentPacket != null ? currentPacket.chunk.length : 1;
currentPacket = largeMessageData.poll(readTimeout, TimeUnit.SECONDS);
currentPacket = largeMessageData.poll(readTimeout, TimeUnit.MILLISECONDS);
if (currentPacket == null) {
throw new IndexOutOfBoundsException();
}