Apply Palantir Java Format

Author: github-actions[bot]

rqueue-core/src/main/java/com/github/sonus21/rqueue/dao/impl/NatsRqueueJobDao.java

@@ -28,11 +28,32 @@
 @Repository
 @Conditional(NatsBackendCondition.class)
 public class NatsRqueueJobDao implements RqueueJobDao {
-  @Override public void createJob(RqueueJob rqueueJob, Duration expiry) {}
-  @Override public void save(RqueueJob rqueueJob, Duration expiry) {}
-  @Override public RqueueJob findById(String jobId) { return null; }
-  @Override public List<RqueueJob> findJobsByIdIn(Collection<String> jobIds) { return Collections.emptyList(); }
-  @Override public List<RqueueJob> finByMessageIdIn(List<String> messageIds) { return Collections.emptyList(); }
-  @Override public List<RqueueJob> finByMessageId(String messageId) { return Collections.emptyList(); }
-  @Override public void delete(String jobId) {}
+  @Override
+  public void createJob(RqueueJob rqueueJob, Duration expiry) {}
+
+  @Override
+  public void save(RqueueJob rqueueJob, Duration expiry) {}
+
+  @Override
+  public RqueueJob findById(String jobId) {
+    return null;
+  }
+
+  @Override
+  public List<RqueueJob> findJobsByIdIn(Collection<String> jobIds) {
+    return Collections.emptyList();
+  }
+
+  @Override
+  public List<RqueueJob> finByMessageIdIn(List<String> messageIds) {
+    return Collections.emptyList();
+  }
+
+  @Override
+  public List<RqueueJob> finByMessageId(String messageId) {
+    return Collections.emptyList();
+  }
+
+  @Override
+  public void delete(String jobId) {}
 }

rqueue-core/src/main/java/com/github/sonus21/rqueue/dao/impl/NatsRqueueSystemConfigDao.java

@@ -23,12 +23,37 @@
 @Repository
 @Conditional(NatsBackendCondition.class)
 public class NatsRqueueSystemConfigDao implements RqueueSystemConfigDao {
-  @Override public QueueConfig getConfigByName(String name) { return null; }
-  @Override public List<QueueConfig> getConfigByNames(Collection<String> names) { return Collections.emptyList(); }
-  @Override public QueueConfig getConfigByName(String name, boolean cached) { return null; }
-  @Override public QueueConfig getQConfig(String id, boolean cached) { return null; }
-  @Override public List<QueueConfig> findAllQConfig(Collection<String> ids) { return Collections.emptyList(); }
-  @Override public void saveQConfig(QueueConfig queueConfig) {}
-  @Override public void saveAllQConfig(List<QueueConfig> newConfigs) {}
-  @Override public void clearCacheByName(String name) {}
+  @Override
+  public QueueConfig getConfigByName(String name) {
+    return null;
+  }
+
+  @Override
+  public List<QueueConfig> getConfigByNames(Collection<String> names) {
+    return Collections.emptyList();
+  }
+
+  @Override
+  public QueueConfig getConfigByName(String name, boolean cached) {
+    return null;
+  }
+
+  @Override
+  public QueueConfig getQConfig(String id, boolean cached) {
+    return null;
+  }
+
+  @Override
+  public List<QueueConfig> findAllQConfig(Collection<String> ids) {
+    return Collections.emptyList();
+  }
+
+  @Override
+  public void saveQConfig(QueueConfig queueConfig) {}
+
+  @Override
+  public void saveAllQConfig(List<QueueConfig> newConfigs) {}
+
+  @Override
+  public void clearCacheByName(String name) {}
 }

rqueue-core/src/main/java/com/github/sonus21/rqueue/web/service/impl/NatsRqueueMessageMetadataService.java

@@ -80,7 +80,8 @@ public void saveMessageMetadataForQueue(
       String queueName, MessageMetadata messageMetadata, Long ttlInMillisecond) {}
 
   @Override
-  public java.util.List<org.springframework.data.redis.core.ZSetOperations.TypedTuple<MessageMetadata>>
+  public java.util.List<
+          org.springframework.data.redis.core.ZSetOperations.TypedTuple<MessageMetadata>>
       readMessageMetadataForQueue(String queueName, long start, long end) {
     return Collections.emptyList();
   }

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/AbstractNatsBootIT.java

@@ -65,12 +65,10 @@ static void natsProps(DynamicPropertyRegistry r) {
     if (USE_EXTERNAL_NATS) {
       r.add("rqueue.nats.connection.url", () -> EXTERNAL_NATS_URL);
     } else {
-      r.add(
-          "rqueue.nats.connection.url",
-          () -> {
-            startNats();
-            return "nats://" + NATS.getHost() + ":" + NATS.getMappedPort(4222);
-          });
+      r.add("rqueue.nats.connection.url", () -> {
+        startNats();
+        return "nats://" + NATS.getHost() + ":" + NATS.getMappedPort(4222);
+      });
     }
   }
 }