Repository: qpid-jms
Updated Branches:
  refs/heads/master 5c59b2739 -> 0e3128c10


QPIDJMS-98 fix sleep to kick in only after the failover.

Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/0e3128c1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/0e3128c1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/0e3128c1

Branch: refs/heads/master
Commit: 0e3128c109e8bf7053d375ddb37f5f65f1ae2bfe
Parents: 5c59b27
Author: Timothy Bish <[email protected]>
Authored: Thu Aug 27 10:14:56 2015 -0400
Committer: Timothy Bish <[email protected]>
Committed: Thu Aug 27 10:14:56 2015 -0400

----------------------------------------------------------------------
 .../test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/0e3128c1/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
----------------------------------------------------------------------
diff --git 
a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
 
b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
index 4a0c10b..271c108 100644
--- 
a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
+++ 
b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
@@ -274,7 +274,7 @@ public class JmsFailoverTest extends AmqpTestSupport {
                         LOG.debug("Producer sening message #{}", i + 1);
                         producer.send(session.createTextMessage("Message: " + 
i));
                         sentSome.countDown();
-                        if (sentSome.getCount() > 0) {
+                        if (sentSome.getCount() <= 0) {
                             TimeUnit.MILLISECONDS.sleep(50);
                         }
                     }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to