QPID-2508, Committing a patch from Emmanuel Bourg

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@936575 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 5 deletions

diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/client/connection/ExceptionListenerTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/client/connection/ExceptionListenerTest.java
index 6f31f7bc65..e87902dad3 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/unit/client/connection/ExceptionListenerTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/unit/client/connection/ExceptionListenerTest.java
@@ -22,8 +22,8 @@ package org.apache.qpid.test.unit.client.connection;
 
 import org.apache.qpid.test.utils.QpidTestCase;
 
-import org.apache.qpid.util.concurrent.Condition;
-
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import javax.jms.Connection;
 import javax.jms.ExceptionListener;
 import javax.jms.JMSException;
@@ -42,18 +42,18 @@ public class ExceptionListenerTest extends QpidTestCase
 
         conn.start();
 
-        final Condition fired = new Condition();
+        final CountDownLatch fired = new CountDownLatch(1);
         conn.setExceptionListener(new ExceptionListener()
         {
             public void onException(JMSException e)
             {
-                fired.set();
+                fired.countDown();
             }
         });
 
         stopBroker();
 
-        if (!fired.get(3000))
+        if (!fired.await(3, TimeUnit.SECONDS))
         {
             fail("exception listener was not fired");
         }