fixed: failing test

Author: sonus21

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/RqueueMessageTemplateTest.java

@@ -53,6 +53,7 @@ class RqueueMessageTemplateTest extends TestBase {
   @Mock
   private RedisConnectionFactory redisConnectionFactory;
 
+  @Mock
   private ListOperations<String, RqueueMessage> listOperations;
 
   @Mock

rqueue-core/src/test/java/com/github/sonus21/rqueue/listener/RqueueMiddlewareTest.java

@@ -70,6 +70,7 @@
 import java.util.UUID;
 import java.util.concurrent.Callable;
 import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.BeforeEach;
@@ -328,19 +329,26 @@ void logAndRateLimiterMiddleware() throws TimedOutException {
         })
         .when(messageHandler)
         .handleMessage(any());
-    Executor executor = Executors.newSingleThreadExecutor();
+    ExecutorService executor = Executors.newFixedThreadPool(4);
     long startTime = System.currentTimeMillis();
-    for (RqueueMessage message : messages) {
-      executor.execute(new RqueueExecutor(
-          rqueueBeanProvider,
-          queueStateMgr,
-          newArrayList(logMiddleware, testRateLimiter),
-          postProcessingHandler,
-          message,
-          queueDetail,
-          queueThreadPool));
+    try {
+      for (RqueueMessage message : messages) {
+        executor.execute(new RqueueExecutor(
+            rqueueBeanProvider,
+            queueStateMgr,
+            newArrayList(logMiddleware, testRateLimiter),
+            postProcessingHandler,
+            message,
+            queueDetail,
+            queueThreadPool));
+      }
+      TimeoutUtils.waitFor(
+          () -> testRateLimiter.jobs.size() == jobCount,
+          20_000L,
+          "all jobs to proceed");
+    } finally {
+      executor.shutdownNow();
     }
-    TimeoutUtils.waitFor(() -> testRateLimiter.jobs.size() == jobCount, "all jobs to proceed");
     long endTime = System.currentTimeMillis();
     // we need to round since rate is at second resolution and execution in millis so we round this
     // to next second

rqueue-core/src/test/java/com/github/sonus21/rqueue/web/service/RqueueUtilityServiceTest.java

@@ -66,6 +66,8 @@ class RqueueUtilityServiceTest extends TestBase {
 
   @Mock
   private RqueueWebConfig rqueueWebConfig;
+
+  @Mock
   private RqueueMessageTemplate rqueueMessageTemplate;
 
   @Mock