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

ARTEMIS-441 correct time-unit for large msg poll

This commit is contained in:
jbertram 2016-03-17 09:22:05 -05:00
parent ab98eb9620
commit 7653d17e6a
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; int sizeToAdd = currentPacket != null ? currentPacket.chunk.length : 1;
currentPacket = largeMessageData.poll(readTimeout, TimeUnit.SECONDS); currentPacket = largeMessageData.poll(readTimeout, TimeUnit.MILLISECONDS);
if (currentPacket == null) { if (currentPacket == null) {
throw new IndexOutOfBoundsException(); throw new IndexOutOfBoundsException();
} }