Update for the recent ConsumerMain constructor change

dpw · dpw · commit 02973d477500 · 2009-08-27T15:09:23.000+01:00
diff --git a/test/src/com/rabbitmq/examples/TestMain.java b/test/src/com/rabbitmq/examples/TestMain.java
@@ -195,7 +195,7 @@ public static void runProducerConsumerTest(String hostName, int portNumber, int
         ProducerMain p = new ProducerMain(connp, 2000, 10000, false, commitEvery, true);
         new Thread(p).start();
         Connection connc = new ConnectionFactory().newConnection(hostName, portNumber);
-        ConsumerMain c = new ConsumerMain(connc, false);
+        ConsumerMain c = new ConsumerMain(connc, false, true);
         c.run();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -195,7 +195,7 @@ public static void runProducerConsumerTest(String hostName, int portNumber, int`
`195`	`195`	`ProducerMain p = new ProducerMain(connp, 2000, 10000, false, commitEvery, true);`
`196`	`196`	`new Thread(p).start();`
`197`	`197`	`Connection connc = new ConnectionFactory().newConnection(hostName, portNumber);`
`198`		`- ConsumerMain c = new ConsumerMain(connc, false);`
	`198`	`+ ConsumerMain c = new ConsumerMain(connc, false, true);`
`199`	`199`	`c.run();`
`200`	`200`	`}`
`201`	`201`