@@ -502,50 +502,6 @@ public void tryTransaction(String queueName) throws IOException {
502502 _ch1 .txCommit ();
503503 expect (2 , drain (10 , queueName , false ));
504504
505- /*
506- TODO: figure out what these tests are meant to do; they
507- currently break due to rollback no longer requeueing
508- delivered messages
509-
510- String x = "txtest";
511- _ch1.exchangeDeclare(x, "direct", true);
512- String requestQueue = _ch1.queueDeclare("", true).getQueue();
513- String replyQueue = _ch1.queueDeclare("", true).getQueue();
514- _ch1.queueBind(requestQueue, x, requestQueue);
515- _ch1.queueBind(replyQueue, x, replyQueue);
516- publish2(x, requestQueue, "Request");
517- _ch1.txCommit();
518-
519- expect(1, drain(10, requestQueue, false));
520- expect(0, drain(10, replyQueue, false));
521- _ch1.txRollback();
522-
523- expect(1, drain(10, requestQueue, false));
524- expect(0, drain(10, replyQueue, false));
525- publish2(x, replyQueue, "Reply");
526- _ch1.txRollback();
527-
528- waitForKey("Temp queues should have ONE REQUEST, no reply");
529-
530- expect(1, drain(10, requestQueue, false));
531- expect(0, drain(10, replyQueue, false));
532- publish2(x, replyQueue, "Reply");
533- _ch1.txCommit();
534-
535- waitForKey("Temp queues should have no request, ONE REPLY");
536-
537- expect(0, drain(10, requestQueue, false));
538- expect(1, drain(10, replyQueue, false));
539- _ch1.txRollback();
540-
541- expect(0, drain(10, requestQueue, false));
542- expect(1, drain(10, replyQueue, false));
543- _ch1.txCommit();
544-
545- _ch1.queueDelete(requestQueue);
546- _ch1.queueDelete(replyQueue);
547-
548- */
549505 }
550506
551507
0 commit comments