Apply Palantir Java Format

Author: github-actions[bot]

rqueue-core/src/test/java/com/github/sonus21/rqueue/listener/RqueueMessageListenerContainerTest.java

@@ -37,8 +37,8 @@
 import com.github.sonus21.rqueue.core.RqueueBeanProvider;
 import com.github.sonus21.rqueue.core.RqueueMessage;
 import com.github.sonus21.rqueue.core.RqueueMessageTemplate;
-import com.github.sonus21.rqueue.models.Concurrency;
 import com.github.sonus21.rqueue.dao.RqueueSystemConfigDao;
+import com.github.sonus21.rqueue.models.Concurrency;
 import com.github.sonus21.rqueue.models.db.MessageMetadata;
 import com.github.sonus21.rqueue.models.db.QueueConfig;
 import com.github.sonus21.rqueue.models.enums.MessageStatus;
@@ -178,7 +178,8 @@ void setTaskExecutor() {
   @Test
   void globalMaxRetryCapsDefaultRetryForever() throws Exception {
     beanProvider.getRqueueConfig().setMaxRetry(5);
-    doReturn(handlerMap(mapping(slowQueue, -1, null))).when(rqueueMessageHandler)
+    doReturn(handlerMap(mapping(slowQueue, -1, null)))
+        .when(rqueueMessageHandler)
         .getHandlerMethodMap();
 
     container.afterPropertiesSet();
@@ -189,7 +190,8 @@ void globalMaxRetryCapsDefaultRetryForever() throws Exception {
   @Test
   void globalMaxRetryDoesNotOverrideExplicitRetryCount() throws Exception {
     beanProvider.getRqueueConfig().setMaxRetry(2);
-    doReturn(handlerMap(mapping(slowQueue, 10, null))).when(rqueueMessageHandler)
+    doReturn(handlerMap(mapping(slowQueue, 10, null)))
+        .when(rqueueMessageHandler)
         .getHandlerMethodMap();
 
     container.afterPropertiesSet();
@@ -200,7 +202,8 @@ void globalMaxRetryDoesNotOverrideExplicitRetryCount() throws Exception {
   @Test
   void globalMaxRetryDoesNotRaiseLowerExplicitRetryCount() throws Exception {
     beanProvider.getRqueueConfig().setMaxRetry(5);
-    doReturn(handlerMap(mapping(slowQueue, 2, null))).when(rqueueMessageHandler)
+    doReturn(handlerMap(mapping(slowQueue, 2, null)))
+        .when(rqueueMessageHandler)
         .getHandlerMethodMap();
 
     container.afterPropertiesSet();
@@ -211,7 +214,8 @@ void globalMaxRetryDoesNotRaiseLowerExplicitRetryCount() throws Exception {
   @Test
   void globalMaxRetryCanDisableRetries() throws Exception {
     beanProvider.getRqueueConfig().setMaxRetry(0);
-    doReturn(handlerMap(mapping(slowQueue, -1, null))).when(rqueueMessageHandler)
+    doReturn(handlerMap(mapping(slowQueue, -1, null)))
+        .when(rqueueMessageHandler)
         .getHandlerMethodMap();
 
     container.afterPropertiesSet();
@@ -222,12 +226,14 @@ void globalMaxRetryCanDisableRetries() throws Exception {
   @Test
   void globalMaxRetryDoesNotOverrideDeadLetterDefaultRetryCount() throws Exception {
     beanProvider.getRqueueConfig().setMaxRetry(0);
-    doReturn(handlerMap(mapping(slowQueue, -1, slowQueue + "-dlq"))).when(rqueueMessageHandler)
+    doReturn(handlerMap(mapping(slowQueue, -1, slowQueue + "-dlq")))
+        .when(rqueueMessageHandler)
         .getHandlerMethodMap();
 
     container.afterPropertiesSet();
 
-    assertEquals(Constants.DEFAULT_RETRY_DEAD_LETTER_QUEUE,
+    assertEquals(
+        Constants.DEFAULT_RETRY_DEAD_LETTER_QUEUE,
         EndpointRegistry.get(slowQueue).getNumRetry());
   }
 

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

@@ -71,11 +71,12 @@ void globalRetryLimitCapsImplicitRetryForever() throws Exception {
     enqueuer.enqueue(QUEUE, "payload");
 
     assertThat(listener.twoAttempts.await(20, TimeUnit.SECONDS)).isTrue();
-    Awaitility.await().during(Duration.ofSeconds(2)).atMost(Duration.ofSeconds(3)).untilAsserted(
-        () -> assertThat(listener.attempts).hasValue(2));
+    Awaitility.await()
+        .during(Duration.ofSeconds(2))
+        .atMost(Duration.ofSeconds(3))
+        .untilAsserted(() -> assertThat(listener.attempts).hasValue(2));
 
-    assertThat(jsm
-            .getConsumerInfo(STREAM_PREFIX + QUEUE, QUEUE + "-consumer")
+    assertThat(jsm.getConsumerInfo(STREAM_PREFIX + QUEUE, QUEUE + "-consumer")
             .getConsumerConfiguration()
             .getMaxDeliver())
         .isEqualTo(3L);

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

@@ -58,8 +58,10 @@ void globalRetryLimitCapsImplicitRetryForever() throws Exception {
     enqueuer.enqueue(QUEUE, "payload");
 
     assertThat(listener.twoAttempts.await(20, TimeUnit.SECONDS)).isTrue();
-    Awaitility.await().during(Duration.ofSeconds(2)).atMost(Duration.ofSeconds(3)).untilAsserted(
-        () -> assertThat(listener.attempts).hasValue(2));
+    Awaitility.await()
+        .during(Duration.ofSeconds(2))
+        .atMost(Duration.ofSeconds(3))
+        .untilAsserted(() -> assertThat(listener.attempts).hasValue(2));
   }
 
   @SpringBootApplication