Merge branch 'nats-backend' of github.com:/sonus21/rqueue into nats-backend

Author: sonus21

rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/NatsStreamValidatorProducerModeTest.java

@@ -75,8 +75,7 @@ void producerMode_skipsConsumerProvisioningButStillEnsuresStream() {
     when(rqueueConfig.getMode()).thenReturn(RqueueMode.PRODUCER);
     when(rqueueConfig.isProducer()).thenReturn(true);
 
-    NatsStreamValidator validator =
-        new NatsStreamValidator(provisioner, natsConfig, rqueueConfig);
+    NatsStreamValidator validator = new NatsStreamValidator(provisioner, natsConfig, rqueueConfig);
     validator.afterSingletonsInstantiated();
 
     verify(provisioner, times(1))
@@ -91,8 +90,7 @@ void consumerMode_provisionsBothStreamAndConsumer() {
     RqueueConfig rqueueConfig = mock(RqueueConfig.class);
     when(rqueueConfig.getMode()).thenReturn(RqueueMode.BOTH);
 
-    NatsStreamValidator validator =
-        new NatsStreamValidator(provisioner, natsConfig, rqueueConfig);
+    NatsStreamValidator validator = new NatsStreamValidator(provisioner, natsConfig, rqueueConfig);
     validator.afterSingletonsInstantiated();
 
     verify(provisioner, times(1))

rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/js/JetStreamMessageBrokerResolveTest.java

@@ -41,7 +41,8 @@ private static QueueDetail queue(long visibilityTimeoutMs, int numRetry) {
   void resolveAckWait_usesVisibilityTimeoutWhenPositive() {
     QueueDetail q = queue(45_000L, 3);
     assertEquals(
-        Duration.ofMillis(45_000L), JetStreamMessageBroker.resolveAckWait(q, RqueueNatsConfig.defaults()));
+        Duration.ofMillis(45_000L),
+        JetStreamMessageBroker.resolveAckWait(q, RqueueNatsConfig.defaults()));
   }
 
   @Test

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

@@ -199,8 +199,8 @@ public NatsProvisioner natsProvisioner(
   @Bean
   @ConditionalOnMissingBean(com.github.sonus21.rqueue.repository.MessageBrowsingRepository.class)
   public com.github.sonus21.rqueue.repository.MessageBrowsingRepository
-  natsMessageBrowsingRepository(
-      JetStreamManagement jetStreamManagement, RqueueNatsProperties props) {
+      natsMessageBrowsingRepository(
+          JetStreamManagement jetStreamManagement, RqueueNatsProperties props) {
     return new com.github.sonus21.rqueue.nats.repository.NatsMessageBrowsingRepository(
         jetStreamManagement, toBrokerConfig(props));
   }
@@ -225,7 +225,7 @@ static RqueueNatsConfig toBrokerConfig(RqueueNatsProperties p) {
         "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.Interest
                 : io.nats.client.api.RetentionPolicy.Limits);
     sd.setMaxMsgs(p.getStream().getMaxMessages());
     sd.setMaxBytes(p.getStream().getMaxBytes());