This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new b727649  Fix not waiting for the compaction completeness on Pulsar 
tests (#4713)
b727649 is described below

commit b7276494a13f13635084f24bc9bb4b996d0c3cb1
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Dec 3 12:01:52 2020 +0100

    Fix not waiting for the compaction completeness on Pulsar tests (#4713)
---
 .../apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
 
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
index e80e64a..39be95e 100644
--- 
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
+++ 
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
@@ -99,7 +99,7 @@ public class PulsarConsumerReadCompactedTest extends 
PulsarTestSupport {
         final Topics topics = givenPulsarAdmin().topics();
 
         topics.triggerCompaction(TOPIC_URI);
-        while 
(!topics.compactionStatus(TOPIC_URI).status.equals(LongRunningProcessStatus.Status.RUNNING))
 {
+        while 
(topics.compactionStatus(TOPIC_URI).status.equals(LongRunningProcessStatus.Status.RUNNING))
 {
             LOGGER.info("Waiting for compaction completeness...");
             Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
         }

Reply via email to