diff options
Diffstat (limited to 'java/common/src/test')
| -rw-r--r-- | java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java b/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java index 8aa8c5f647..6554b135f5 100644 --- a/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java +++ b/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java @@ -160,7 +160,7 @@ public class ConnectionTest extends TestCase implements SessionListener private Connection connect(final Condition closed) { Connection conn = new Connection(); - conn.setConnectionListener(new ConnectionListener() + conn.addConnectionListener(new ConnectionListener() { public void opened(Connection conn) {} public void exception(Connection conn, ConnectionException exc) @@ -311,7 +311,7 @@ public class ConnectionTest extends TestCase implements SessionListener startServer(); Connection conn = new Connection(); - conn.setConnectionListener(new FailoverConnectionListener()); + conn.addConnectionListener(new FailoverConnectionListener()); conn.connect("localhost", port, null, "guest", "guest"); Session ssn = conn.createSession(1); ssn.setSessionListener(new TestSessionListener()); @@ -366,7 +366,7 @@ public class ConnectionTest extends TestCase implements SessionListener startServer(); Connection conn = new Connection(); - conn.setConnectionListener(new FailoverConnectionListener()); + conn.addConnectionListener(new FailoverConnectionListener()); conn.connect("localhost", port, null, "guest", "guest"); Session ssn = conn.createSession(1); ssn.setSessionListener(new TestSessionListener()); |