Fix flaky test_retained_per_message_expire

We don't need to delay processing of message nodes in testing mode. #110
halfgaar · Jul 9, 2024 · 13a44a1 · 13a44a1
1 parent 97dfaf5
commit 13a44a1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/threaddata.cpp b/threaddata.cpp
@@ -682,7 +682,12 @@ void ThreadData::removeExpiredRetainedMessages()
     if (!done)
     {
         auto f = std::bind(&ThreadData::removeExpiredRetainedMessages, this);
+
+#ifdef TESTING
+        addImmediateTask(f);
+#else
         addDelayedTask(f, 100);
+#endif
     }
 }