From d36b4e5ebf15a2ceac2f5f10370031d7d55a979d Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Thu, 29 Nov 2007 03:54:53 +0000
Subject: Setting the message to null to mark for garbage collection noAck
 still has to clear our internal command ids. increased the default max
 prefetch to 1000

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599255 13f79535-47bb-0310-9956-ffa450edef68
---
 .../src/main/java/org/apache/qpid/client/AMQSession_0_10.java       | 5 ++++-
 .../main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 6 +++---
 2 files changed, 7 insertions(+), 4 deletions(-)

(limited to 'java/client/src')

diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
index c809ec04d9..81ba795fa4 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
@@ -60,7 +60,7 @@ public class AMQSession_0_10 extends AMQSession
     /**
      * The maximum number of pre-fetched messages per destination
      */
-    public static final long MAX_PREFETCH = 100;
+    public static long MAX_PREFETCH = 1000;
 
     /**
      * The underlying QpidSession
@@ -98,6 +98,9 @@ public class AMQSession_0_10 extends AMQSession
 
         super(con, channelId, transacted, acknowledgeMode, messageFactoryRegistry, defaultPrefetchHighMark,
               defaultPrefetchLowMark);
+
+        MAX_PREFETCH = Integer.parseInt(System.getProperty("max_prefetch","1000"));
+
         // create the qpid session with an expiry  <= 0 so that the session does not expire
         _qpidSession = qpidConnection.createSession(0);
         // set the exception listnere for this session
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
index 6e9b145896..e1a3d15a78 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
@@ -230,10 +230,10 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
     {
         // notify the session
         ((AMQSession_0_10) getSession()).addMessageTag(msg.getDeliveryTag());
-        if (!Boolean.getBoolean("noAck"))
-        {
+        //if (!Boolean.getBoolean("noAck"))
+        //{
             super.postDeliver(msg);
-        }
+        //}
     }
 
     void notifyMessage(UnprocessedMessage messageFrame, int channelId)
-- 
cgit v1.2.1