Apply Palantir Java Format

Author: github-actions[bot]

rqueue-core/src/main/java/com/github/sonus21/rqueue/core/EndpointRegistry.java

@@ -116,9 +116,8 @@ public static List<String> getActiveQueues() {
 
   public static List<QueueDetail> getActiveQueueDetails() {
     synchronized (lock) {
-      List<QueueDetail> queueDetails = registry.values().stream()
-          .filter(QueueDetail::isActive)
-          .collect(Collectors.toList());
+      List<QueueDetail> queueDetails =
+          registry.values().stream().filter(QueueDetail::isActive).collect(Collectors.toList());
       lock.notifyAll();
       return queueDetails;
     }

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/internal/NatsProvisioner.java

@@ -153,7 +153,9 @@ public void ensureStream(String streamName, List<String> subjects) {
           if (sd.getMaxBytes() > 0) {
             b.maxBytes(sd.getMaxBytes());
           }
-          if (sd.getMaxAge() != null && !sd.getMaxAge().isZero() && !sd.getMaxAge().isNegative()) {
+          if (sd.getMaxAge() != null
+              && !sd.getMaxAge().isZero()
+              && !sd.getMaxAge().isNegative()) {
             b.maxAge(sd.getMaxAge());
           }
           jsm.addStream(b.build());
@@ -192,7 +194,8 @@ public String ensureConsumer(
       if (cached != null) {
         return cached;
       }
-      String actual = doEnsureConsumer(streamName, consumerName, ackWait, maxDeliver, maxAckPending);
+      String actual =
+          doEnsureConsumer(streamName, consumerName, ackWait, maxDeliver, maxAckPending);
       consumerCache.put(cacheKey, actual);
       return actual;
     }
@@ -228,14 +231,16 @@ private String doEnsureConsumer(
         throw new RqueueNatsException("Consumer '" + consumerName + "' on stream '" + streamName
             + "' does not exist and autoCreateConsumers=false");
       }
-      jsm.addOrUpdateConsumer(streamName, ConsumerConfiguration.builder()
-          .durable(consumerName)
-          .ackPolicy(AckPolicy.Explicit)
-          .deliverPolicy(DeliverPolicy.All)
-          .ackWait(ackWait)
-          .maxDeliver(maxDeliver)
-          .maxAckPending(maxAckPending)
-          .build());
+      jsm.addOrUpdateConsumer(
+          streamName,
+          ConsumerConfiguration.builder()
+              .durable(consumerName)
+              .ackPolicy(AckPolicy.Explicit)
+              .deliverPolicy(DeliverPolicy.All)
+              .ackWait(ackWait)
+              .maxDeliver(maxDeliver)
+              .maxAckPending(maxAckPending)
+              .build());
       return consumerName;
     } catch (JetStreamApiException e) {
       throw new RqueueNatsException(

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js/NatsStreamValidator.java

@@ -152,11 +152,7 @@ private void tryEnsureConsumer(
       RqueueNatsConfig.ConsumerDefaults cd) {
     try {
       provisioner.ensureConsumer(
-          streamName,
-          consumerName,
-          cd.getAckWait(),
-          cd.getMaxDeliver(),
-          cd.getMaxAckPending());
+          streamName, consumerName, cd.getAckWait(), cd.getMaxDeliver(), cd.getMaxAckPending());
     } catch (RqueueNatsException e) {
       failures.add("consumer " + consumerName + " on " + streamName + ": " + rootCause(e));
     }

rqueue-spring-boot-example/src/main/java/com/github/sonus21/rqueue/example/BaseListener.java

@@ -2,11 +2,11 @@
 
 import com.github.sonus21.rqueue.core.RqueueMessageManager;
 import com.github.sonus21.rqueue.utils.TimeoutUtils;
+import java.util.Random;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Lazy;
-import java.util.Random;
 
 @Slf4j
 public abstract class BaseListener {

rqueue-spring-boot-example/src/main/java/com/github/sonus21/rqueue/example/MessageListener.java

@@ -16,15 +16,9 @@
 
 package com.github.sonus21.rqueue.example;
 
-import com.github.sonus21.rqueue.annotation.RqueueHandler;
 import com.github.sonus21.rqueue.annotation.RqueueListener;
-import com.github.sonus21.rqueue.core.RqueueMessageManager;
 import com.github.sonus21.rqueue.listener.RqueueMessageHeaders;
-import com.github.sonus21.rqueue.utils.TimeoutUtils;
-import java.util.Random;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.stereotype.Component;
 
@@ -45,7 +39,6 @@ public void onMessage(String message) {
     execute("delay: {}", message, true);
   }
 
-
   @RqueueListener(
       value = "sch-job-queue",
       deadLetterQueue = "job-morgue",

rqueue-spring-boot-starter/src/main/java/com/github/sonus21/rqueue/spring/boot/RqueueNatsAutoConfig.java

@@ -210,14 +210,16 @@ static RqueueNatsConfig toBrokerConfig(RqueueNatsProperties p) {
 
     RqueueNatsConfig.StreamDefaults sd = new RqueueNatsConfig.StreamDefaults();
     sd.setReplicas(p.getStream().getReplicas());
-    sd.setStorage("MEMORY".equalsIgnoreCase(p.getStream().getStorage())
-        ? io.nats.client.api.StorageType.Memory
-        : io.nats.client.api.StorageType.File);
-    sd.setRetention("WORKQUEUE".equalsIgnoreCase(p.getStream().getRetention())
-        ? io.nats.client.api.RetentionPolicy.WorkQueue
-        : "INTEREST".equalsIgnoreCase(p.getStream().getRetention())
-            ? io.nats.client.api.RetentionPolicy.Interest
-            : io.nats.client.api.RetentionPolicy.Limits);
+    sd.setStorage(
+        "MEMORY".equalsIgnoreCase(p.getStream().getStorage())
+            ? io.nats.client.api.StorageType.Memory
+            : io.nats.client.api.StorageType.File);
+    sd.setRetention(
+        "WORKQUEUE".equalsIgnoreCase(p.getStream().getRetention())
+            ? io.nats.client.api.RetentionPolicy.WorkQueue
+            : "INTEREST".equalsIgnoreCase(p.getStream().getRetention())
+                ? io.nats.client.api.RetentionPolicy.Interest
+                : io.nats.client.api.RetentionPolicy.Limits);
     sd.setMaxMsgs(p.getStream().getMaxMessages());
     sd.setMaxBytes(p.getStream().getMaxBytes());
     sd.setMaxAge(p.getStream().getMaxAge());