Merge pull request #6388 from y3haha/fix_worker

Fixed - worker stop working #6387

redisson/src/main/java/org/redisson/RedissonRemoteService.java

@@ -264,7 +264,7 @@ public class RedissonRemoteService extends BaseRemoteService implements RRemoteS
                 }
 
                 int freeWorkers = entry.getFreeWorkers().decrementAndGet();
-                if (freeWorkers > 0 && requestId != null) {
+                if (freeWorkers > 0) {
                     subscribe(remoteInterface, requestQueue, executor, bean);
                 }
 

redisson/src/test/java/org/redisson/executor/RedissonExecutorServiceTest.java

@@ -694,4 +694,21 @@ public class RedissonExecutorServiceTest extends RedisDockerTest {
         assertThat(counter.get()).isGreaterThan(0);
     }
 
+    @Test
+    public void testSubmitAfterPause() throws InterruptedException {
+
+        RExecutorService redissonES = redisson.getExecutorService("test-worker");
+        redissonES.registerWorkers(WorkerOptions.defaults().workers(2));
+
+        redissonES.submit(new RunnableTask());
+        Thread.sleep(Duration.ofSeconds(1));
+        assertThat(redissonES.getTaskCount()).isEqualTo(0);
+
+        Thread.sleep(Duration.ofMinutes(1));
+
+        redissonES.submit(new RunnableTask());
+        Thread.sleep(Duration.ofSeconds(1));
+        assertThat(redissonES.getTaskCount()).isEqualTo(0);
+    }
+
 }