From 9ebd8a5bd4dd60e5983cfa998fea1c78fdb87401 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Mon, 13 Oct 2008 16:07:01 +0000 Subject: QPID-1339: - Removed the Channel class in order to simplify the state management surrounding Sessions and Connections. - Consolidated the ChannelDelegate into the ConnectionDelegate. - Modified MethodDelegate to invoke a generic handle method as the default action for each dispatched method. - Modified the code generator to produce a separate ConnectionInvoker and SessionInvoker. - Modified the invoker template to use package level visibility for all controls rather than public visibility. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@704147 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/qpid/transport/ConnectionTest.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) (limited to 'qpid/java/common/src/test') diff --git a/qpid/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java b/qpid/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java index e61ffb501b..03fae56250 100644 --- a/qpid/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java +++ b/qpid/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java @@ -51,10 +51,10 @@ public class ConnectionTest extends TestCase port = AvailablePortFinder.getNextAvailable(12000); ConnectionDelegate server = new ServerDelegate() { - @Override public void connectionOpen(Channel ch, ConnectionOpen open) + @Override public void connectionOpen(Connection conn, ConnectionOpen open) { - super.connectionOpen(ch, open); - ch.getConnection().close(); + super.connectionOpen(conn, open); + conn.close(); } }; @@ -94,13 +94,9 @@ public class ConnectionTest extends TestCase fail("never got notified of connection close"); } - Channel ch = conn.getChannel(0); - Session ssn = new Session("test".getBytes()); - ssn.attach(ch); - try { - ssn.sessionAttach(ssn.getName()); + conn.connectionCloseOk(); fail("writing to a closed socket succeeded"); } catch (TransportException e) -- cgit v1.2.1