Apply Palantir Java Format

github-actions[bot] · github-actions[bot] · commit f342ceda885e · 2026-05-02T06:16:16.000Z
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/converter/GenericMessageConverter.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/converter/GenericMessageConverter.java
@@ -57,8 +57,8 @@ public class GenericMessageConverter implements SmartMessageConverter {
   private final SmartMessageSerDes smartMessageSerDes;
 
   public GenericMessageConverter() {
-    this.smartMessageSerDes = new SmartMessageSerDes(
-        SerializationUtils.getSerDes(), SerializationUtils.getTypeFactory());
+    this.smartMessageSerDes =
+        new SmartMessageSerDes(SerializationUtils.getSerDes(), SerializationUtils.getTypeFactory());
   }
 
   public GenericMessageConverter(RqueueSerDes serDes, RqueueTypeFactory typeFactory) {
@@ -131,6 +131,7 @@ private static class Msg {
     @JsonSerialize(using = Utf8BytesSerializer.class)
     @JsonDeserialize(using = Utf8BytesDeserializer.class)
     private byte[] msg;
+
     private String name;
   }
 
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/core/RqueueInternalPubSubChannel.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/core/RqueueInternalPubSubChannel.java
@@ -118,7 +118,8 @@ private void processEvent(byte[] body) {
             handlePauseEvent(rqueuePubSubEvent.messageAs(serDes, PauseUnpauseQueueRequest.class));
             break;
           case QUEUE_CRUD:
-            rqueueBeanProvider.getRqueueSystemConfigDao()
+            rqueueBeanProvider
+                .getRqueueSystemConfigDao()
                 .clearCacheByName(rqueuePubSubEvent.messageAs(serDes, String.class));
             break;
           default:
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/RqueueSerDes.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/RqueueSerDes.java
@@ -9,7 +9,6 @@
  */
 package com.github.sonus21.rqueue.serdes;
 
-import tools.jackson.databind.JavaType;
 import java.io.IOException;
 
 /**
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/SerializationUtils.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/SerializationUtils.java
@@ -36,8 +36,7 @@ public final class SerializationUtils {
   @Getter
   public static RqueueTypeFactory typeFactory = new RqJacksonTypeFactory(objectMapper);
 
-  private SerializationUtils() {
-  }
+  private SerializationUtils() {}
 
   public static boolean isEmpty(byte[] bytes) {
     return bytes == null || bytes.length == 0;
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/TypeEnvelop.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/serdes/TypeEnvelop.java
@@ -1,4 +1,3 @@
 package com.github.sonus21.rqueue.serdes;
 
-public interface TypeEnvelop {
-}
+public interface TypeEnvelop {}
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/utils/HttpUtils.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/utils/HttpUtils.java
@@ -17,16 +17,15 @@
 package com.github.sonus21.rqueue.utils;
 
 import com.github.sonus21.rqueue.config.RqueueConfig;
+import com.github.sonus21.rqueue.serdes.SerializationUtils;
 import java.net.InetSocketAddress;
 import java.net.ProxySelector;
 import java.net.URI;
 import java.net.http.HttpClient;
 import java.net.http.HttpRequest;
 import java.net.http.HttpResponse;
 import java.time.Duration;
-import com.github.sonus21.rqueue.serdes.SerializationUtils;
 import lombok.extern.slf4j.Slf4j;
-import tools.jackson.databind.ObjectMapper;
 
 @Slf4j
 public final class HttpUtils {
diff --git a/rqueue-core/src/main/java/com/github/sonus21/rqueue/worker/RqueueWorkerRegistryImpl.java b/rqueue-core/src/main/java/com/github/sonus21/rqueue/worker/RqueueWorkerRegistryImpl.java
@@ -23,10 +23,10 @@
 import com.github.sonus21.rqueue.models.registry.RqueueWorkerInfo;
 import com.github.sonus21.rqueue.models.registry.RqueueWorkerPollerMetadata;
 import com.github.sonus21.rqueue.models.registry.RqueueWorkerPollerView;
-import com.github.sonus21.rqueue.utils.DateTimeUtils;
-import com.github.sonus21.rqueue.utils.QueueThreadPool;
 import com.github.sonus21.rqueue.serdes.RqueueSerDes;
 import com.github.sonus21.rqueue.serdes.SerializationUtils;
+import com.github.sonus21.rqueue.utils.DateTimeUtils;
+import com.github.sonus21.rqueue.utils.QueueThreadPool;
 import com.github.sonus21.rqueue.utils.StringUtils;
 import java.lang.management.ManagementFactory;
 import java.net.InetAddress;
diff --git a/rqueue-core/src/test/java/com/github/sonus21/rqueue/converter/GenericMessageConverterTest.java b/rqueue-core/src/test/java/com/github/sonus21/rqueue/converter/GenericMessageConverterTest.java
@@ -17,14 +17,12 @@
 package com.github.sonus21.rqueue.converter;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertNull;
 
 import com.github.sonus21.TestBase;
 import com.github.sonus21.rqueue.CoreUnitTest;
 import com.github.sonus21.rqueue.listener.RqueueMessageHeaders;
 import com.github.sonus21.rqueue.serdes.SerializationUtils;
-import tools.jackson.databind.ObjectMapper;
 import java.lang.reflect.GenericArrayType;
 import java.lang.reflect.ParameterizedType;
 import java.lang.reflect.Type;
@@ -50,6 +48,7 @@
 import tools.jackson.core.JsonParser;
 import tools.jackson.databind.DeserializationContext;
 import tools.jackson.databind.JsonNode;
+import tools.jackson.databind.ObjectMapper;
 import tools.jackson.databind.SerializationContext;
 import tools.jackson.databind.deser.std.StdDeserializer;
 import tools.jackson.databind.module.SimpleModule;
@@ -179,31 +178,31 @@ void backwardCompatibility() throws Exception {
     ObjectMapper mapper = SerializationUtils.getObjectMapper();
 
     Comment unicodeComment = new Comment("u-1", "Héllo 你好 🎉");
-    Comment asciiComment   = new Comment("a-1", "plain ascii");
-    Email   specialEmail   = new Email("e-2", "subject: re: hello & goodbye");
+    Comment asciiComment = new Comment("a-1", "plain ascii");
+    Email specialEmail = new Email("e-2", "subject: re: hello & goodbye");
 
     // 5 cases: class name is straightforward for non-generic POJOs
     Object[][] cases = {
-        {comment,       comment.getClass().getName()},
-        {email,         email.getClass().getName()},
-        {unicodeComment, unicodeComment.getClass().getName()},
-        {asciiComment,  asciiComment.getClass().getName()},
-        {specialEmail,  specialEmail.getClass().getName()},
+      {comment, comment.getClass().getName()},
+      {email, email.getClass().getName()},
+      {unicodeComment, unicodeComment.getClass().getName()},
+      {asciiComment, asciiComment.getClass().getName()},
+      {specialEmail, specialEmail.getClass().getName()},
     };
 
     for (Object[] c : cases) {
-      Object payload   = c[0];
+      Object payload = c[0];
       String className = (String) c[1];
 
       // Build old-format JSON: {"msg":"<json-string>","name":"<className>"}
-      String innerJson  = mapper.writeValueAsString(payload);
+      String innerJson = mapper.writeValueAsString(payload);
       String oldFormatJson = mapper.writeValueAsString(new OldMsg(innerJson, className));
 
-      Object restored = genericMessageConverter.fromMessage(
-          new GenericMessage<>(oldFormatJson), null);
+      Object restored =
+          genericMessageConverter.fromMessage(new GenericMessage<>(oldFormatJson), null);
 
-      assertEquals(payload, restored,
-          "old String-format data must deserialise correctly for " + className);
+      assertEquals(
+          payload, restored, "old String-format data must deserialise correctly for " + className);
     }
   }
 
diff --git a/rqueue-core/src/test/java/com/github/sonus21/rqueue/converter/JsonMessageConverterTest.java b/rqueue-core/src/test/java/com/github/sonus21/rqueue/converter/JsonMessageConverterTest.java
@@ -22,6 +22,8 @@
 
 import com.github.sonus21.TestBase;
 import com.github.sonus21.rqueue.CoreUnitTest;
+import com.github.sonus21.rqueue.serdes.RqJacksonSerDes;
+import com.github.sonus21.rqueue.serdes.RqueueSerDes;
 import java.util.UUID;
 import lombok.AllArgsConstructor;
 import lombok.Data;
@@ -31,16 +33,15 @@
 import org.junit.jupiter.api.Test;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.converter.MessageConverter;
-import com.github.sonus21.rqueue.serdes.RqJacksonSerDes;
-import com.github.sonus21.rqueue.serdes.RqueueSerDes;
 import tools.jackson.databind.DeserializationFeature;
 import tools.jackson.databind.json.JsonMapper;
 
 @CoreUnitTest
 class JsonMessageConverterTest extends TestBase {
 
-  private final RqueueSerDes serDes = new RqJacksonSerDes(
-      JsonMapper.builder().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false).build());
+  private final RqueueSerDes serDes = new RqJacksonSerDes(JsonMapper.builder()
+      .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
+      .build());
   private final MessageConverter messageConverter = new JsonMessageConverter();
   private final MessageConverter messageConverter2 = new JsonMessageConverter(serDes);
 
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueJobDao.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueJobDao.java
@@ -51,7 +51,8 @@ public class NatsRqueueJobDao implements RqueueJobDao {
   private final NatsProvisioner provisioner;
   private final com.github.sonus21.rqueue.serdes.RqueueSerDes serdes;
 
-  public NatsRqueueJobDao(NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
+  public NatsRqueueJobDao(
+      NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
     this.provisioner = provisioner;
     this.serdes = serdes;
   }
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueQStatsDao.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueQStatsDao.java
@@ -56,7 +56,8 @@ public class NatsRqueueQStatsDao implements RqueueQStatsDao {
   private final NatsProvisioner provisioner;
   private final com.github.sonus21.rqueue.serdes.RqueueSerDes serdes;
 
-  public NatsRqueueQStatsDao(NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
+  public NatsRqueueQStatsDao(
+      NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
     this.provisioner = provisioner;
     this.serdes = serdes;
   }
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueSystemConfigDao.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueSystemConfigDao.java
@@ -51,7 +51,8 @@ public class NatsRqueueSystemConfigDao implements RqueueSystemConfigDao {
   private final com.github.sonus21.rqueue.serdes.RqueueSerDes serdes;
   private final ConcurrentHashMap<String, QueueConfig> cache = new ConcurrentHashMap<>();
 
-  public NatsRqueueSystemConfigDao(NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
+  public NatsRqueueSystemConfigDao(
+      NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
     this.provisioner = provisioner;
     this.serdes = serdes;
   }
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js/JetStreamMessageBroker.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js/JetStreamMessageBroker.java
@@ -248,11 +248,11 @@ public Mono<Void> enqueueReactive(QueueDetail q, RqueueMessage m) {
             ? e
             : new RqueueNatsException(
                 "Failed to enqueue message id="
-                + m.getId()
-                + " queue="
-                + q.getName()
-                + " subject="
-                + subject,
+                    + m.getId()
+                    + " queue="
+                    + q.getName()
+                    + " subject="
+                    + subject,
                 e))
         .then();
   }
@@ -673,8 +673,8 @@ public JetStreamMessageBroker build() {
           management = connection.jetStreamManagement();
         }
         if (provisioner == null) {
-          provisioner = new NatsProvisioner(connection, management,
-              config != null ? config : RqueueNatsConfig.defaults());
+          provisioner = new NatsProvisioner(
+              connection, management, config != null ? config : RqueueNatsConfig.defaults());
         }
       } catch (IOException e) {
         throw new RqueueNatsException("Failed to derive JetStream context from connection", e);
@@ -685,8 +685,8 @@ public JetStreamMessageBroker build() {
       if (serdes == null) {
         serdes = new RqJacksonSerDes(SerializationUtils.getObjectMapper());
       }
-      return new JetStreamMessageBroker(connection, jetStream, management, config, serdes,
-          provisioner);
+      return new JetStreamMessageBroker(
+          connection, jetStream, management, config, serdes, provisioner);
     }
 
     /**
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/service/NatsRqueueMessageMetadataService.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/service/NatsRqueueMessageMetadataService.java
@@ -60,7 +60,8 @@ public class NatsRqueueMessageMetadataService implements RqueueMessageMetadataSe
   private final NatsProvisioner provisioner;
   private final com.github.sonus21.rqueue.serdes.RqueueSerDes serdes;
 
-  public NatsRqueueMessageMetadataService(NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
+  public NatsRqueueMessageMetadataService(
+      NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
     this.provisioner = provisioner;
     this.serdes = serdes;
   }
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/service/NatsRqueueUtilityService.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/service/NatsRqueueUtilityService.java
@@ -39,7 +39,8 @@
 @Conditional(NatsBackendCondition.class)
 public class NatsRqueueUtilityService implements RqueueUtilityService {
 
-  @Autowired private RqueueWebConfig rqueueWebConfig;
+  @Autowired
+  private RqueueWebConfig rqueueWebConfig;
 
   private static <T extends BaseResponse> T notSupported(T response, String op) {
     response.setCode(1);
@@ -152,7 +153,8 @@ private List<Pair<String, String>> getDailyDateCounter() {
         for (int date : dates) {
           if (date == i) {
             String suffix = i == 1 ? "day" : "days";
-            dateSelector.add(new Pair<>(String.valueOf(date), String.format("Last %d %s", date, suffix)));
+            dateSelector.add(
+                new Pair<>(String.valueOf(date), String.format("Last %d %s", date, suffix)));
             break;
           }
         }
@@ -165,7 +167,8 @@ private List<Pair<String, String>> getDailyDateCounter() {
   private List<Pair<String, String>> getWeeklyDateCounter() {
     List<Pair<String, String>> dateSelector = new LinkedList<>();
     dateSelector.add(new Pair<>("0", "Select"));
-    int nWeek = (int) Math.ceil(rqueueWebConfig.getHistoryDay() / (double) Constants.DAYS_IN_A_WEEK);
+    int nWeek =
+        (int) Math.ceil(rqueueWebConfig.getHistoryDay() / (double) Constants.DAYS_IN_A_WEEK);
     for (int week = 1; week <= nWeek; week++) {
       String suffix = week == 1 ? "week" : "weeks";
       dateSelector.add(new Pair<>(String.valueOf(week), String.format("Last %d %s", week, suffix)));
@@ -176,10 +179,12 @@ private List<Pair<String, String>> getWeeklyDateCounter() {
   private List<Pair<String, String>> getMonthlyDateCounter() {
     List<Pair<String, String>> dateSelector = new LinkedList<>();
     dateSelector.add(new Pair<>("0", "Select"));
-    int nMonths = (int) Math.ceil(rqueueWebConfig.getHistoryDay() / (double) Constants.DAYS_IN_A_MONTH);
+    int nMonths =
+        (int) Math.ceil(rqueueWebConfig.getHistoryDay() / (double) Constants.DAYS_IN_A_MONTH);
     for (int month = 1; month <= nMonths; month++) {
       String suffix = month == 1 ? "month" : "months";
-      dateSelector.add(new Pair<>(String.valueOf(month), String.format("Last %d %s", month, suffix)));
+      dateSelector.add(
+          new Pair<>(String.valueOf(month), String.format("Last %d %s", month, suffix)));
     }
     return dateSelector;
   }
diff --git a/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/worker/NatsWorkerRegistryStore.java b/rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/worker/NatsWorkerRegistryStore.java
@@ -73,7 +73,8 @@ public class NatsWorkerRegistryStore implements WorkerRegistryStore {
   /** Captured on first putQueueHeartbeat / refreshQueueTtl so heartbeat bucket gets the right maxAge. */
   private volatile Duration heartbeatBucketTtl;
 
-  public NatsWorkerRegistryStore(NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
+  public NatsWorkerRegistryStore(
+      NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {
     this.provisioner = provisioner;
     this.serdes = serdes;
   }
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerDelayThrowsTest.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerDelayThrowsTest.java
@@ -35,8 +35,12 @@ private JetStreamMessageBroker newBroker() {
     JetStream js = mock(JetStream.class);
     JetStreamManagement jsm = mock(JetStreamManagement.class);
     return new JetStreamMessageBroker(
-        conn, js, jsm, RqueueNatsConfig.defaults(),
-        new RqJacksonSerDes(SerializationUtils.getObjectMapper()), null);
+        conn,
+        js,
+        jsm,
+        RqueueNatsConfig.defaults(),
+        new RqJacksonSerDes(SerializationUtils.getObjectMapper()),
+        null);
   }
 
   @Test
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerUnitTest.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerUnitTest.java
@@ -65,9 +65,8 @@ private static Fixture newFixture(RqueueNatsConfig config) {
     } catch (IOException | JetStreamApiException unreachable) {
       throw new AssertionError(unreachable);
     }
-    JetStreamMessageBroker broker =
-        new JetStreamMessageBroker(conn, js, jsm, config,
-            new RqJacksonSerDes(SerializationUtils.getObjectMapper()), null);
+    JetStreamMessageBroker broker = new JetStreamMessageBroker(
+        conn, js, jsm, config, new RqJacksonSerDes(SerializationUtils.getObjectMapper()), null);
     return new Fixture(conn, js, jsm, broker);
   }
 
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueJobDaoIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueJobDaoIT.java
@@ -18,8 +18,8 @@
 import com.github.sonus21.rqueue.models.enums.JobStatus;
 import com.github.sonus21.rqueue.nats.AbstractJetStreamIT;
 import com.github.sonus21.rqueue.nats.RqueueNatsConfig;
-import com.github.sonus21.rqueue.serdes.RqJacksonSerDes;
 import com.github.sonus21.rqueue.nats.internal.NatsProvisioner;
+import com.github.sonus21.rqueue.serdes.RqJacksonSerDes;
 import com.github.sonus21.rqueue.serdes.SerializationUtils;
 import io.nats.client.JetStreamApiException;
 import io.nats.client.KeyValueManagement;
@@ -45,7 +45,8 @@ void freshBucket() throws IOException, JetStreamApiException {
     }
     NatsProvisioner provisioner = new NatsProvisioner(
         connection, connection.jetStreamManagement(), RqueueNatsConfig.defaults());
-    dao = new NatsRqueueJobDao(provisioner, new RqJacksonSerDes(SerializationUtils.getObjectMapper()));
+    dao = new NatsRqueueJobDao(
+        provisioner, new RqJacksonSerDes(SerializationUtils.getObjectMapper()));
   }
 
   private RqueueJob job(String id, String messageId) {
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueSystemConfigDaoIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/dao/NatsRqueueSystemConfigDaoIT.java
@@ -16,8 +16,8 @@
 import com.github.sonus21.rqueue.models.db.QueueConfig;
 import com.github.sonus21.rqueue.nats.AbstractJetStreamIT;
 import com.github.sonus21.rqueue.nats.RqueueNatsConfig;
-import com.github.sonus21.rqueue.serdes.RqJacksonSerDes;
 import com.github.sonus21.rqueue.nats.internal.NatsProvisioner;
+import com.github.sonus21.rqueue.serdes.RqJacksonSerDes;
 import com.github.sonus21.rqueue.serdes.SerializationUtils;
 import io.nats.client.JetStreamApiException;
 import io.nats.client.KeyValueManagement;
@@ -42,7 +42,8 @@ void freshBucket() throws IOException, JetStreamApiException {
     }
     NatsProvisioner provisioner = new NatsProvisioner(
         connection, connection.jetStreamManagement(), RqueueNatsConfig.defaults());
-    dao = new NatsRqueueSystemConfigDao(provisioner, new RqJacksonSerDes(SerializationUtils.getObjectMapper()));
+    dao = new NatsRqueueSystemConfigDao(
+        provisioner, new RqJacksonSerDes(SerializationUtils.getObjectMapper()));
   }
 
   private QueueConfig sample(String id, String name) {
diff --git a/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/service/NatsRqueueMessageMetadataServiceIT.java b/rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/service/NatsRqueueMessageMetadataServiceIT.java
diff --git a/rqueue-spring-boot-starter/src/main/java/com/github/sonus21/rqueue/spring/boot/RqueueNatsAutoConfig.java b/rqueue-spring-boot-starter/src/main/java/com/github/sonus21/rqueue/spring/boot/RqueueNatsAutoConfig.java
diff --git a/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/integration/CustomMessageConverterTest.java b/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/integration/CustomMessageConverterTest.java
diff --git a/rqueue-web/src/main/java/com/github/sonus21/rqueue/web/service/impl/RqueueJobServiceImpl.java b/rqueue-web/src/main/java/com/github/sonus21/rqueue/web/service/impl/RqueueJobServiceImpl.java
diff --git a/rqueue-web/src/main/java/com/github/sonus21/rqueue/web/service/impl/RqueueQDetailServiceImpl.java b/rqueue-web/src/main/java/com/github/sonus21/rqueue/web/service/impl/RqueueQDetailServiceImpl.java
diff --git a/rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueQDetailServiceBrokerRoutingTest.java b/rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueQDetailServiceBrokerRoutingTest.java

Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,8 @@ public class NatsRqueueJobDao implements RqueueJobDao {`
`51`	`51`	`private final NatsProvisioner provisioner;`
`52`	`52`	`private final com.github.sonus21.rqueue.serdes.RqueueSerDes serdes;`
`53`	`53`
`54`		`- public NatsRqueueJobDao(NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {`
	`54`	`+ public NatsRqueueJobDao(`
	`55`	`+ NatsProvisioner provisioner, com.github.sonus21.rqueue.serdes.RqueueSerDes serdes) {`
`55`	`56`	`this.provisioner = provisioner;`
`56`	`57`	`this.serdes = serdes;`
`57`	`58`	`}`