activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r618615 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
Date Tue, 05 Feb 2008 12:01:25 GMT
Author: rajdavies
Date: Tue Feb  5 04:01:19 2008
New Revision: 618615

URL: http://svn.apache.org/viewvc?rev=618615&view=rev
Log:
don't set memory limit

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java?rev=618615&r1=618614&r2=618615&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
Tue Feb  5 04:01:19 2008
@@ -91,7 +91,7 @@
             });
 
             final Message m2 = template1.receive("test2.q");
-
+            assertNotNull(m2);
             assertTrue(m2 instanceof TextMessage);
 
             final TextMessage tm2 = (TextMessage)m2;
@@ -118,14 +118,14 @@
         brokerService.setUseJmx(true);
 
         final SystemUsage memoryManager = new SystemUsage();
-        memoryManager.getMemoryUsage().setLimit(10);
+        //memoryManager.getMemoryUsage().setLimit(10);
         brokerService.setSystemUsage(memoryManager);
 
         final List<PolicyEntry> policyEntries = new ArrayList<PolicyEntry>();
 
         final PolicyEntry entry = new PolicyEntry();
         entry.setQueue(">");
-        entry.setMemoryLimit(1);
+        //entry.setMemoryLimit(1);
         policyEntries.add(entry);
 
         final PolicyMap policyMap = new PolicyMap();
@@ -142,7 +142,7 @@
             final NetworkConnector nc = new DiscoveryNetworkConnector(new URI("static:" +
uri2));
             nc.setBridgeTempDestinations(true);
             nc.setBrokerName(brokerName);
-            nc.setPrefetchSize(1);
+            //nc.setPrefetchSize(1);
             brokerService.addNetworkConnector(nc);
         }
 



Mime
View raw message