summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
Diffstat (limited to 'java')
-rw-r--r--java/common/src/test/java/org/apache/qpidity/transport/ConnectionTest.java20
1 files changed, 8 insertions, 12 deletions
diff --git a/java/common/src/test/java/org/apache/qpidity/transport/ConnectionTest.java b/java/common/src/test/java/org/apache/qpidity/transport/ConnectionTest.java
index 55d53ebaae..0c5c69c1f1 100644
--- a/java/common/src/test/java/org/apache/qpidity/transport/ConnectionTest.java
+++ b/java/common/src/test/java/org/apache/qpidity/transport/ConnectionTest.java
@@ -90,9 +90,15 @@ public class ConnectionTest extends TestCase
return conn;
}
- public void testWriteToClosed() throws Exception
+ public void testClosedNotificationAndWriteToClosed() throws Exception
{
- Connection conn = connect(null);
+ Condition closed = new Condition();
+ Connection conn = connect(closed);
+ if (!closed.get(3000))
+ {
+ fail("never got notified of connection close");
+ }
+
Channel ch = conn.getChannel(0);
Session ssn = new Session();
ssn.attach(ch);
@@ -108,14 +114,4 @@ public class ConnectionTest extends TestCase
}
}
- public void testClosedNotification() throws Exception
- {
- Condition closed = new Condition();
- Connection conn = connect(closed);
- if (!closed.get(3000))
- {
- fail("never got notified of connection close");
- }
- }
-
}