activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1408919 - /activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
Date Tue, 13 Nov 2012 19:49:49 GMT
Author: chirino
Date: Tue Nov 13 19:49:48 2012
New Revision: 1408919

URL: http://svn.apache.org/viewvc?rev=1408919&view=rev
Log:
Use more sensible prefetch settings.

Modified:
    activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java

Modified: activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java?rev=1408919&r1=1408918&r2=1408919&view=diff
==============================================================================
--- activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
(original)
+++ activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
Tue Nov 13 19:49:48 2012
@@ -84,7 +84,7 @@ class AmqpProtocolConverter {
 //    private CONNECT connect;
 //    private String clientId;
 //    private final String QOS_PROPERTY_NAME = "QoSPropertyName";
-
+    int prefetch = 100;
 
     TransportImpl protonTransport = new TransportImpl();
     ConnectionImpl protonConnection = new ConnectionImpl();
@@ -615,7 +615,7 @@ class AmqpProtocolConverter {
         if( remoteTarget instanceof Coordinator ) {
             pumpProtonToSocket();
             receiver.setContext(coordinatorContext);
-            receiver.flow(1024 * 64);
+            receiver.flow(prefetch);
             receiver.open();
             pumpProtonToSocket();
         } else {
@@ -635,7 +635,7 @@ class AmqpProtocolConverter {
             ProducerContext producerContext = new ProducerContext(producerId, dest);
 
             receiver.setContext(producerContext);
-            receiver.flow(1024 * 64);
+            receiver.flow(prefetch);
             ProducerInfo producerInfo = new ProducerInfo(producerId);
             producerInfo.setDestination(dest);
             sendToActiveMQ(producerInfo, new ResponseHandler() {



Mime
View raw message