Apply Palantir Java Format

Author: github-actions[bot]

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

@@ -123,8 +123,7 @@ protected Object enqueue(
       messageBroker.enqueue(queueDetail, priority, rqueueMessage);
     } else {
       if (reactive) {
-        return messageBroker.enqueueWithDelayReactive(
-            queueDetail, rqueueMessage, delayInMilliSecs);
+        return messageBroker.enqueueWithDelayReactive(queueDetail, rqueueMessage, delayInMilliSecs);
       }
       messageBroker.enqueueWithDelay(queueDetail, rqueueMessage, delayInMilliSecs);
     }

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

@@ -19,7 +19,6 @@
 import static org.springframework.util.Assert.isTrue;
 import static org.springframework.util.Assert.notNull;
 
-import com.github.sonus21.rqueue.common.RqueueLockManager;
 import com.github.sonus21.rqueue.core.EndpointRegistry;
 import com.github.sonus21.rqueue.core.RqueueMessage;
 import com.github.sonus21.rqueue.core.RqueueMessageIdGenerator;
@@ -35,7 +34,6 @@
 import java.util.ArrayList;
 import java.util.List;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageHeaders;
 import org.springframework.messaging.converter.MessageConverter;

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/RqueueEndpointManagerImplTest.java

@@ -74,10 +74,7 @@ class RqueueEndpointManagerImplTest extends TestBase {
   public void init() throws IllegalAccessException {
     MockitoAnnotations.openMocks(this);
     rqueueEndpointManager = new RqueueEndpointManagerImpl(
-        messageTemplate,
-        new RedisMessageBroker(messageTemplate),
-        messageConverter,
-        messageHeaders);
+        messageTemplate, new RedisMessageBroker(messageTemplate), messageConverter, messageHeaders);
     RqueueConfig rqueueConfig = new RqueueConfig(redisConnectionFactory, null, false, 1);
     FieldUtils.writeField(rqueueEndpointManager, "rqueueConfig", rqueueConfig, true);
     FieldUtils.writeField(

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/unit/RqueueListenerAutoConfigTest.java

@@ -135,10 +135,7 @@ void rqueueMessageEnqueuerWiresBroker() throws IllegalAccessException {
     FieldUtils.writeField(messageAutoConfig, "simpleRqueueListenerContainerFactory", factory, true);
 
     RqueueMessageEnqueuer enqueuer = messageAutoConfig.rqueueMessageEnqueuer(
-        rqueueMessageHandler,
-        messageTemplate,
-        messageBroker,
-        new UuidV4RqueueMessageIdGenerator());
+        rqueueMessageHandler, messageTemplate, messageBroker, new UuidV4RqueueMessageIdGenerator());
 
     assertNotNull(enqueuer);
     // Broker is on the enqueuer (inherited from BaseMessageSender), not on the template — that
@@ -157,10 +154,7 @@ void rqueueMessageSenderUsesConfiguredMessageConverter() throws IllegalAccessExc
     FieldUtils.writeField(messageAutoConfig, "simpleRqueueListenerContainerFactory", factory, true);
     doReturn(messageConverter).when(rqueueMessageHandler).getMessageConverter();
     RqueueMessageEnqueuer messageSender = messageAutoConfig.rqueueMessageEnqueuer(
-        rqueueMessageHandler,
-        messageTemplate,
-        messageBroker,
-        new UuidV4RqueueMessageIdGenerator());
+        rqueueMessageHandler, messageTemplate, messageBroker, new UuidV4RqueueMessageIdGenerator());
     MessageConverter converter = messageSender.getMessageConverter();
     assertTrue(converter.hashCode() == messageConverter.hashCode());
   }