special connection closing message

Alexandru Scvortov · Alexandru Scvortov · commit 42ce342e278b · 2011-07-13T17:21:13.000+01:00
diff --git a/src/com/rabbitmq/client/impl/ChannelN.java b/src/com/rabbitmq/client/impl/ChannelN.java
@@ -188,7 +188,7 @@ public void waitForConfirmsOrDie()
         throws IOException, InterruptedException
     {
         if (!waitForConfirms()) {
-            close(AMQP.REPLY_SUCCESS, "OK", true,
+            close(AMQP.REPLY_SUCCESS, "NACKS RECEIVED", true,
                   new RuntimeException("received nack"), false);
             throw new IOException(Utility.fixStackTrace(getCloseReason()));
         }
diff --git a/test/src/com/rabbitmq/client/test/functional/Confirm.java b/test/src/com/rabbitmq/client/test/functional/Confirm.java
@@ -261,7 +261,9 @@ public void testWaitForConfirmsException()
         try {
             channel.waitForConfirmsOrDie();
             fail("waitAcks worked on a closed channel");
-        } catch (IOException e) {
+        } catch (IOException ioe) {
+            if (ioe.getCause() == null || !(ioe.getCause() instanceof RuntimeException))
+                fail("got the wrong exception :(");
             //whoosh; everything ok
         } catch (InterruptedException e) {
             // whoosh; we should probably re-run, though

Original file line number	Diff line number	Diff line change
`@@ -188,7 +188,7 @@ public void waitForConfirmsOrDie()`
`188`	`188`	`throws IOException, InterruptedException`
`189`	`189`	`{`
`190`	`190`	`if (!waitForConfirms()) {`
`191`		`- close(AMQP.REPLY_SUCCESS, "OK", true,`
	`191`	`+ close(AMQP.REPLY_SUCCESS, "NACKS RECEIVED", true,`
`192`	`192`	`new RuntimeException("received nack"), false);`
`193`	`193`	`throw new IOException(Utility.fixStackTrace(getCloseReason()));`
`194`	`194`	`}`