Update for new rabbitmqctl interface.

Simon MacMullen · Simon MacMullen · commit 440d17408e97 · 2011-05-20T16:21:00.000+01:00
diff --git a/test/src/com/rabbitmq/client/test/server/Firehose.java b/test/src/com/rabbitmq/client/test/server/Firehose.java
@@ -60,10 +60,10 @@ private void checkHeaders(Map<String, Object> pubHeaders) {
     }
 
     private void enable() throws IOException {
-        Host.rabbitmqctl("set_env trace_exchanges '[{<<\"/\">>, <<\"trace\">>}]'");
+        Host.rabbitmqctl("start_tracing trace");
     }
 
     private void disable() throws IOException {
-        Host.rabbitmqctl("unset_env trace_exchanges");
+        Host.rabbitmqctl("stop_tracing");
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -60,10 +60,10 @@ private void checkHeaders(Map<String, Object> pubHeaders) {`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`private void enable() throws IOException {`
`63`		`- Host.rabbitmqctl("set_env trace_exchanges '[{<<\"/\">>, <<\"trace\">>}]'");`
	`63`	`+ Host.rabbitmqctl("start_tracing trace");`
`64`	`64`	`}`
`65`	`65`
`66`	`66`	`private void disable() throws IOException {`
`67`		`- Host.rabbitmqctl("unset_env trace_exchanges");`
	`67`	`+ Host.rabbitmqctl("stop_tracing");`
`68`	`68`	`}`
`69`	`69`	`}`