fix stovelistener for testing

Trendyol · May 1, 2024 · 2a007c2 · 2a007c2
1 parent 1bdb6d1
commit 2a007c2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...est/kotlin/com/trendyol/stove/testing/e2e/standalone/kafka/setup/example/StoveListener.kt b/...est/kotlin/com/trendyol/stove/testing/e2e/standalone/kafka/setup/example/StoveListener.kt
@@ -25,7 +25,7 @@ abstract class StoveListener(
   suspend fun start() {
     consumer.subscribe(listOf(topicDefinition.topic, topicDefinition.retryTopic, topicDefinition.deadLetterTopic))
     consuming = GlobalScope.launch {
-      while (!this.isActive) {
+      while (isActive) {
         consumer
           .poll(Duration.ofMillis(100))
           .forEach { message ->