[automatic failover] Add rate limiter to test MultiThreadedFakeApp (#4248)

* Add option for rate limiter to MultiThreadedFakeApp

* retrigger checks

Author: ggivo

src/test/java/redis/clients/jedis/scenario/MultiThreadedFakeApp.java

@@ -1,5 +1,8 @@
 package redis.clients.jedis.scenario;
 
+import io.github.resilience4j.ratelimiter.RateLimiter;
+import io.github.resilience4j.ratelimiter.RateLimiterConfig;
+import io.github.resilience4j.ratelimiter.RateLimiterRegistry;
 import redis.clients.jedis.UnifiedJedis;
 import redis.clients.jedis.exceptions.JedisConnectionException;
 
@@ -11,10 +14,21 @@
 public class MultiThreadedFakeApp extends FakeApp {
 
   private final ExecutorService executorService;
+  private final RateLimiter rateLimiter;
 
   public MultiThreadedFakeApp(UnifiedJedis client, FakeApp.ExecutedAction action, int numThreads) {
+    this(client, action, numThreads, null);
+  }
+
+  public MultiThreadedFakeApp(UnifiedJedis client, FakeApp.ExecutedAction action, int numThreads, RateLimiterConfig config) {
     super(client, action);
     this.executorService = Executors.newFixedThreadPool(numThreads);
+
+    if (config != null) {
+      this.rateLimiter = RateLimiterRegistry.of(config).rateLimiter("fakeAppLimiter");
+    } else {
+      this.rateLimiter = null;
+    }
   }
 
   @Override
@@ -28,6 +42,9 @@ public void run() {
         Duration.ofSeconds(checkEachSeconds), Duration.ofSeconds(keepExecutingForSeconds),
         Duration.ofSeconds(timeoutSeconds))) {
       try {
+        if (rateLimiter != null) {
+          RateLimiter.waitForPermission(rateLimiter);
+        }
         executorService.submit(() -> action.run(client));
       } catch (JedisConnectionException e) {
         log.error("Error executing action", e);