activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: ARTEMIS-441 correct time-unit for large msg poll
Date Thu, 17 Mar 2016 17:56:40 GMT
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 <jbertram@apache.org>
Authored: Thu Mar 17 09:22:05 2016 -0500
Committer: jbertram <jbertram@apache.org>
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();
          }


Mime
View raw message