Run the first test for a longer time, so in 2.7.1 we can see memory alarsm going off.

Author: Simon MacMullen

test/src/com/rabbitmq/examples/perf/PerformanceMain.java

@@ -53,7 +53,7 @@ private static void writeJSON() throws IOException {
     private static void runStaticBrokerTests() throws Exception {
         Broker broker = Broker.HIPE_COARSE;
         broker.start();
-        runTests(new Scenario[]{no_consume(), no_ack(), no_ack_mandatory(), no_ack_immediate(), ack(),
+        runTests(new Scenario[]{no_ack_long(), no_consume(), no_ack(), no_ack_mandatory(), no_ack_immediate(), ack(),
                                 ack_confirm(), ack_confirm_persist(), ack_persist(), fill_drain_queue("small", 500000),
                                 fill_drain_queue("large", 1000000), consumers(),
                                 message_sizes(), message_size_vs_producers(), rate_vs_latency()});
@@ -69,6 +69,12 @@ private static void runTests(Scenario[] scenarios) throws Exception {
         }
     }
 
+    private static Scenario no_ack_long() throws IOException, InterruptedException {
+        MulticastParams params = params();
+        params.setTimeLimit(500);
+        return new SimpleScenario("no-ack-long", factory, 10000, params);
+    }
+
     private static Scenario no_consume() throws IOException, InterruptedException {
         MulticastParams params = params();
         params.setConsumerCount(0);

test/src/com/rabbitmq/examples/perf/RateVsLatencyScenario.java

@@ -34,7 +34,7 @@ public RateVsLatencyScenario(String name, ConnectionFactory factory, MulticastPa
 
     @Override
     public void run() throws Exception {
-        SimpleScenario s = new SimpleScenario(factory, params);
+        SimpleScenario s = new SimpleScenario("untitled", factory, params);
         s.run();
         SimpleScenarioStats m = s.getStats();
         int maxRate = (int) (m.getRecvRate() + m.getSendRate()) / 2;

test/src/com/rabbitmq/examples/perf/SimpleScenario.java

@@ -26,19 +26,19 @@ public class SimpleScenario implements Scenario {
     private MulticastParams[] params;
     private SimpleScenarioStats stats;
 
-    public SimpleScenario(ConnectionFactory factory, MulticastParams... params) {
-        this("untitled", factory, params);
+    public SimpleScenario(String name, ConnectionFactory factory, MulticastParams... params) {
+        this(name, factory, 1000L, params);
     }
 
-    public SimpleScenario(String name, ConnectionFactory factory, MulticastParams... params) {
+    public SimpleScenario(String name, ConnectionFactory factory, long interval, MulticastParams... params) {
         this.name = name;
         this.factory = factory;
         this.params = params;
+        this.stats = new SimpleScenarioStats(interval);
     }
 
     @Override
     public void run() throws IOException, InterruptedException {
-        stats = new SimpleScenarioStats(1000L);
         for (MulticastParams p : params) {
             MulticastSet set = new MulticastSet(stats, factory, p);
             set.run();