Merge branch 'nats-backend' of github.com:/sonus21/rqueue into nats-backend

Author: sonus21

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/worker/NatsWorkerRegistryStore.java

@@ -136,7 +136,8 @@ public Map<String, RqueueWorkerInfo> getWorkerInfos(Collection<String> workerKey
   @Override
   public void putQueueHeartbeat(String queueKey, String workerId, String metadataJson) {
     if (heartbeatBucketTtl == null) {
-      // Best-effort default — overwritten by refreshQueueTtl when the registry computes the real value.
+      // Best-effort default — overwritten by refreshQueueTtl when the registry computes the real
+      // value.
       heartbeatBucketTtl = Duration.ofHours(1);
     }
     try {
@@ -202,8 +203,7 @@ public void refreshQueueTtl(String queueKey, Duration ttl) {
 
   // ---- helpers ----------------------------------------------------------
 
-  private KeyValue ensureBucket(
-      AtomicReference<KeyValue> ref, String bucketName, Duration maxAge)
+  private KeyValue ensureBucket(AtomicReference<KeyValue> ref, String bucketName, Duration maxAge)
       throws IOException, JetStreamApiException {
     KeyValue cached = ref.get();
     if (cached != null) {

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/common/RqueueLockManagerImplTest.java

@@ -22,9 +22,9 @@
 
 import com.github.sonus21.TestBase;
 import com.github.sonus21.rqueue.CoreUnitTest;
-import com.github.sonus21.rqueue.redis.common.impl.RqueueLockManagerImpl;
-import com.github.sonus21.rqueue.dao.RqueueStringDao;
 import com.github.sonus21.rqueue.common.RqueueLockManager;
+import com.github.sonus21.rqueue.dao.RqueueStringDao;
+import com.github.sonus21.rqueue.redis.common.impl.RqueueLockManagerImpl;
 import java.time.Duration;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/MessageSchedulerDisabledTest.java

@@ -24,12 +24,12 @@
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.models.event.RqueueBootstrapEvent;
 import com.github.sonus21.rqueue.utils.TestUtils;
 import com.github.sonus21.rqueue.utils.ThreadUtils;
 import com.github.sonus21.test.TestTaskScheduler;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import org.apache.commons.lang3.reflect.FieldUtils;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/MessageSchedulerTest.java

@@ -23,12 +23,12 @@
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
-import com.github.sonus21.rqueue.redis.core.ScheduledQueueMessageSchedulerTest.TestScheduledQueueMessageScheduler;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.models.event.RqueueBootstrapEvent;
+import com.github.sonus21.rqueue.redis.core.ScheduledQueueMessageSchedulerTest.TestScheduledQueueMessageScheduler;
 import com.github.sonus21.rqueue.utils.TestUtils;
 import com.github.sonus21.test.TestTaskScheduler;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import java.util.HashMap;
 import java.util.Map;
 import org.apache.commons.lang3.reflect.FieldUtils;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/MessageSchedulingTest.java

@@ -27,14 +27,14 @@
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
-import com.github.sonus21.rqueue.redis.core.ProcessingQueueMessageSchedulerTest.ProcessingQTestMessageScheduler;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
+import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.models.event.RqueueBootstrapEvent;
+import com.github.sonus21.rqueue.redis.core.ProcessingQueueMessageSchedulerTest.ProcessingQTestMessageScheduler;
 import com.github.sonus21.rqueue.utils.TestUtils;
 import com.github.sonus21.rqueue.utils.ThreadUtils;
 import com.github.sonus21.test.TestTaskScheduler;
-import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/ProcessingQueueMessageSchedulerTest.java

@@ -24,9 +24,9 @@
 import com.github.sonus21.TestBase;
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.utils.TestUtils;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import java.util.concurrent.Future;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.junit.jupiter.api.BeforeEach;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/RedisAndNormalSchedulingTest.java

@@ -11,16 +11,16 @@
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
-import com.github.sonus21.rqueue.redis.core.ScheduledQueueMessageSchedulerTest.TestScheduledQueueMessageScheduler;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
+import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.models.event.RqueueBootstrapEvent;
+import com.github.sonus21.rqueue.redis.core.ScheduledQueueMessageSchedulerTest.TestScheduledQueueMessageScheduler;
 import com.github.sonus21.rqueue.utils.Constants;
 import com.github.sonus21.rqueue.utils.TestUtils;
 import com.github.sonus21.rqueue.utils.ThreadUtils;
 import com.github.sonus21.rqueue.utils.TimeoutUtils;
 import com.github.sonus21.test.TestTaskScheduler;
-import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 import lombok.extern.slf4j.Slf4j;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/RedisScheduleTriggerHandlerTest.java

@@ -10,11 +10,11 @@
 import com.github.sonus21.TestBase;
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
+import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.utils.TestUtils;
 import com.github.sonus21.rqueue.utils.TimeoutUtils;
-import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import java.util.List;
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutorService;

rqueue-redis/src/test/java/com/github/sonus21/rqueue/redis/core/ScheduledQueueMessageSchedulerTest.java

@@ -34,14 +34,14 @@
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.config.RqueueConfig;
 import com.github.sonus21.rqueue.config.RqueueSchedulerConfig;
+import com.github.sonus21.rqueue.core.EndpointRegistry;
+import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
 import com.github.sonus21.rqueue.listener.QueueDetail;
 import com.github.sonus21.rqueue.models.event.RqueueBootstrapEvent;
 import com.github.sonus21.rqueue.utils.TestUtils;
 import com.github.sonus21.rqueue.utils.ThreadUtils;
 import com.github.sonus21.rqueue.utils.TimeoutUtils;
 import com.github.sonus21.test.TestTaskScheduler;
-import com.github.sonus21.rqueue.core.RqueueRedisListenerContainerFactory;
-import com.github.sonus21.rqueue.core.EndpointRegistry;
 import java.util.Map;
 import java.util.concurrent.Future;
 import java.util.concurrent.atomic.AtomicInteger;