1 files changed, 9 insertions, 9 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 bdd3a0c93b..375a326654 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
@@ -424,10 +424,6 @@ public class ConnectionTest extends QpidTestCase implements SessionListener
         }
     }
 
-    /**
-     * The 0-10 {@code executionSync} command should set the exception status in the session,
-     * so that the client session object can then throw it as an {@link AMQException}.
-     */
     public void testExecutionExceptionSync() throws Exception
     {
         startServer();
@@ -436,11 +432,15 @@ public class ConnectionTest extends QpidTestCase implements SessionListener
         conn.connect("localhost", port, null, "guest", "guest");
         Session ssn = conn.createSession();
         send(ssn, "EXCP 0", true);
-        ExecutionException before = ssn.getException();
-        assertNull("There should not be an exception stored in the session", before);
-        ssn.sync();
-        ExecutionException after = ssn.getException();
-        assertNotNull("There should be an exception stored in the session", after);
+        try
+        {
+            ssn.sync();
+            fail("this should have failed");
+        }
+        catch (SessionException exc)
+        {
+            assertNotNull(exc.getException());
+        }
     }
 
 }