You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/02/05 13:01:25 UTC
svn commit: r618615 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
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);
}