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

Author: sonus21

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/internal/NatsProvisioner.java

@@ -204,13 +204,15 @@ private String doEnsureConsumer(
       if (info != null) {
         ConsumerConfiguration cc = info.getConsumerConfiguration();
         if (cc.getAckWait() != null && !cc.getAckWait().equals(ackWait)) {
-          log.log(Level.WARNING,
+          log.log(
+              Level.WARNING,
               "Consumer " + streamName + "/" + consumerName
                   + " ackWait differs (existing=" + cc.getAckWait()
                   + ", desired=" + ackWait + ") - leaving existing config in place.");
         }
         if (cc.getMaxDeliver() != maxDeliver) {
-          log.log(Level.WARNING,
+          log.log(
+              Level.WARNING,
               "Consumer " + streamName + "/" + consumerName
                   + " maxDeliver differs (existing=" + cc.getMaxDeliver()
                   + ", desired=" + maxDeliver + ") - leaving existing config in place.");

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js/NatsStreamValidator.java

@@ -158,7 +158,11 @@ private void tryEnsureConsumer(
       String filterSubject) {
     try {
       provisioner.ensureConsumer(
-          streamName, consumerName, cd.getAckWait(), cd.getMaxDeliver(), cd.getMaxAckPending(),
+          streamName,
+          consumerName,
+          cd.getAckWait(),
+          cd.getMaxDeliver(),
+          cd.getMaxAckPending(),
           filterSubject);
     } catch (RqueueNatsException e) {
       failures.add("consumer " + consumerName + " on " + streamName + ": " + rootCause(e));