@@ -427,10 +427,10 @@ public void tryTopics() throws IOException {
427427 String q2 = "tryTopicsQueue2" ;
428428 String q3 = "tryTopicsQueue3" ;
429429 String x = "tryTopicsExch" ;
430- _ch1 .queueDeclare (q1 , false , false , false , null );
431- _ch1 .queueDeclare (q2 , false , false , false , null );
432- _ch1 .queueDeclare (q3 , false , false , false , null );
433- _ch1 .exchangeDeclare (x , "topic" , false , false , null );
430+ _ch1 .queueDeclare (q1 , false , true , true , null );
431+ _ch1 .queueDeclare (q2 , false , true , true , null );
432+ _ch1 .queueDeclare (q3 , false , true , true , null );
433+ _ch1 .exchangeDeclare (x , "topic" , false , true , null );
434434 _ch1 .queueBind (q1 , x , "test.#" );
435435 _ch1 .queueBind (q2 , x , "test.test" );
436436 _ch1 .queueBind (q3 , x , "*.test.#" );
@@ -447,12 +447,6 @@ public void tryTopics() throws IOException {
447447 expect (1 , drain (10 , q2 , true ));
448448 log ("About to drain q3" );
449449 expect (2 , drain (10 , q3 , true ));
450-
451- _ch1 .queueDelete (q3 , true , true );
452- _ch1 .queueDelete (q2 , true , true );
453- _ch1 .queueDelete (q1 , true , true );
454- // We created the exchange auto_delete - it should be gone by this point.
455- // ch1.exchangeDelete(x);
456450 }
457451
458452 public void doBasicReturn (BlockingCell cell , int expectedCode ) {
0 commit comments