You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2015/09/18 13:18:47 UTC
svn commit: r1703810 -
/qpid/java/trunk/tools/src/main/java/org/apache/qpid/tools/MemoryConsumptionTestClient.java
Author: orudyy
Date: Fri Sep 18 11:18:46 2015
New Revision: 1703810
URL: http://svn.apache.org/viewvc?rev=1703810&view=rev
Log:
QPID-6742: Use low prefetch on consumer session for purging the queue
Modified:
qpid/java/trunk/tools/src/main/java/org/apache/qpid/tools/MemoryConsumptionTestClient.java
Modified: qpid/java/trunk/tools/src/main/java/org/apache/qpid/tools/MemoryConsumptionTestClient.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/tools/src/main/java/org/apache/qpid/tools/MemoryConsumptionTestClient.java?rev=1703810&r1=1703809&r2=1703810&view=diff
==============================================================================
--- qpid/java/trunk/tools/src/main/java/org/apache/qpid/tools/MemoryConsumptionTestClient.java (original)
+++ qpid/java/trunk/tools/src/main/java/org/apache/qpid/tools/MemoryConsumptionTestClient.java Fri Sep 18 11:18:46 2015
@@ -54,6 +54,7 @@ import javax.naming.InitialContext;
import javax.naming.NamingException;
import com.sun.management.GarbageCollectionNotificationInfo;
+import org.apache.qpid.client.AMQConnection;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -294,7 +295,7 @@ public class MemoryConsumptionTestClient
LOGGER.debug("Consuming left over messages, using receive timeout:" + receiveTimeout);
Connection connection = connectionFactory.createConnection();
- Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Session session = ((AMQConnection)connection).createSession(false, Session.AUTO_ACKNOWLEDGE, 10);
Destination destination = session.createQueue(queueString);
MessageConsumer consumer = session.createConsumer(destination);
connection.start();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org