You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2009/02/26 16:25:17 UTC
svn commit: r748178 -
/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java
Author: rhs
Date: Thu Feb 26 15:25:14 2009
New Revision: 748178
URL: http://svn.apache.org/viewvc?rev=748178&view=rev
Log:
don't run tests when broker doesn't start
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java
Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java?rev=748178&r1=748177&r2=748178&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java (original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java Thu Feb 26 15:25:14 2009
@@ -229,11 +229,13 @@
private LineNumberReader in;
private String ready;
private CountDownLatch latch;
+ private boolean seenReady;
public Piper(InputStream in, String ready)
{
this.in = new LineNumberReader(new InputStreamReader(in));
this.ready = ready;
+ this.seenReady = false;
if (this.ready != null && !this.ready.equals(""))
{
this.latch = new CountDownLatch(1);
@@ -257,7 +259,8 @@
}
else
{
- return latch.await(timeout, unit);
+ latch.await(timeout, unit);
+ return seenReady;
}
}
@@ -271,6 +274,7 @@
System.out.println(line);
if (latch != null && line.contains(ready))
{
+ seenReady = true;
latch.countDown();
}
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org