Code formatting

SolaceLabs · Jan 1, 2024 · 3b52eea · 3b52eea
1 parent 02f0bac
commit 3b52eea
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/.../src/main/java/io/quarkiverse/solace/incoming/IncomingMessagesUnsignedCounterBarrier.java b/.../src/main/java/io/quarkiverse/solace/incoming/IncomingMessagesUnsignedCounterBarrier.java
@@ -1,13 +1,13 @@
 package io.quarkiverse.solace.incoming;
 
-import io.quarkiverse.solace.i18n.SolaceLogging;
-
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
+import io.quarkiverse.solace.i18n.SolaceLogging;
+
 class IncomingMessagesUnsignedCounterBarrier {
     private final AtomicLong counter; // Treated as an unsigned long (i.e. range from 0 -> -1)
     private final Lock awaitLock = new ReentrantLock();
@@ -61,7 +61,8 @@ public boolean awaitEmpty(long timeout, TimeUnit unit) throws InterruptedExcepti
         awaitLock.lock();
         try {
             if (timeout > 0) {
-                SolaceLogging.log.info(String.format("Waiting for %s items, time remaining: %s %s", counter.get(), timeout, unit));
+                SolaceLogging.log
+                        .info(String.format("Waiting for %s items, time remaining: %s %s", counter.get(), timeout, unit));
                 final long expiry = unit.toMillis(timeout) + System.currentTimeMillis();
                 while (isGreaterThanZero()) {
                     long realTimeout = expiry - System.currentTimeMillis();

diff --git a/.../src/main/java/io/quarkiverse/solace/outgoing/OutgoingMessagesUnsignedCounterBarrier.java b/.../src/main/java/io/quarkiverse/solace/outgoing/OutgoingMessagesUnsignedCounterBarrier.java
@@ -1,13 +1,13 @@
 package io.quarkiverse.solace.outgoing;
 
-import io.quarkiverse.solace.i18n.SolaceLogging;
-
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
+import io.quarkiverse.solace.i18n.SolaceLogging;
+
 class OutgoingMessagesUnsignedCounterBarrier {
     private final AtomicLong counter; // Treated as an unsigned long (i.e. range from 0 -> -1)
     private final Lock awaitLock = new ReentrantLock();
@@ -61,7 +61,8 @@ public boolean awaitEmpty(long timeout, TimeUnit unit) throws InterruptedExcepti
         awaitLock.lock();
         try {
             if (timeout > 0) {
-                SolaceLogging.log.info(String.format("Waiting for %s items, time remaining: %s %s", counter.get(), timeout, unit));
+                SolaceLogging.log
+                        .info(String.format("Waiting for %s items, time remaining: %s %s", counter.get(), timeout, unit));
                 final long expiry = unit.toMillis(timeout) + System.currentTimeMillis();
                 while (isGreaterThanZero()) {
                     long realTimeout = expiry - System.currentTimeMillis();