Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

don't set memory limit 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618615 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-02-05 12:01:19 +00:00
parent 0c1279009c
commit c24574c801
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
View File

@ -91,7 +91,7 @@ public class AMQStackOverFlowTest extends TestCase {
}); });
final Message m2 = template1.receive("test2.q"); final Message m2 = template1.receive("test2.q");
assertNotNull(m2);
assertTrue(m2 instanceof TextMessage); assertTrue(m2 instanceof TextMessage);
final TextMessage tm2 = (TextMessage)m2; final TextMessage tm2 = (TextMessage)m2;
@ -118,14 +118,14 @@ public class AMQStackOverFlowTest extends TestCase {
brokerService.setUseJmx(true); brokerService.setUseJmx(true);
final SystemUsage memoryManager = new SystemUsage(); final SystemUsage memoryManager = new SystemUsage();
memoryManager.getMemoryUsage().setLimit(10); //memoryManager.getMemoryUsage().setLimit(10);
brokerService.setSystemUsage(memoryManager); brokerService.setSystemUsage(memoryManager);
final List<PolicyEntry> policyEntries = new ArrayList<PolicyEntry>(); final List<PolicyEntry> policyEntries = new ArrayList<PolicyEntry>();
final PolicyEntry entry = new PolicyEntry(); final PolicyEntry entry = new PolicyEntry();
entry.setQueue(">"); entry.setQueue(">");
entry.setMemoryLimit(1); //entry.setMemoryLimit(1);
policyEntries.add(entry); policyEntries.add(entry);
final PolicyMap policyMap = new PolicyMap(); final PolicyMap policyMap = new PolicyMap();
@ -142,7 +142,7 @@ public class AMQStackOverFlowTest extends TestCase {
final NetworkConnector nc = new DiscoveryNetworkConnector(new URI("static:" + uri2)); final NetworkConnector nc = new DiscoveryNetworkConnector(new URI("static:" + uri2));
nc.setBridgeTempDestinations(true); nc.setBridgeTempDestinations(true);
nc.setBrokerName(brokerName); nc.setBrokerName(brokerName);
nc.setPrefetchSize(1); //nc.setPrefetchSize(1);
brokerService.addNetworkConnector(nc); brokerService.addNetworkConnector(nc);
} }