From 914e177239f012a3794caaf6ee15f4b9764bfce8 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Tue, 13 Nov 2012 19:49:48 +0000 Subject: [PATCH] Use more sensible prefetch settings. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1408919 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/transport/amqp/AmqpProtocolConverter.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java index 2d6012b2d5..fbd0df0d08 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java @@ -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() {