Repository: activemq-artemis Updated Branches: refs/heads/master ab98eb962 -> 57c1c338e
ARTEMIS-441 correct time-unit for large msg poll Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/7653d17e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/7653d17e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/7653d17e Branch: refs/heads/master Commit: 7653d17e6ace6e37effdca706b96ca327cd7b04e Parents: ab98eb9 Author: jbertram <[email protected]> Authored: Thu Mar 17 09:22:05 2016 -0500 Committer: jbertram <[email protected]> Committed: Thu Mar 17 09:22:14 2016 -0500 ---------------------------------------------------------------------- .../artemis/core/client/impl/LargeMessageControllerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/7653d17e/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java ---------------------------------------------------------------------- diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java index 289181e..77134ee 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java @@ -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(); }
