Enhance timeout handling with nanosecond precision

Refactor timeout calculation in `MessageConsumerImpl` to use `System.nanoTime()` for improved precision and reliability. Replaced the previous millisecond-based logic with a deadline-driven approach, ensuring more accurate waiting periods under various conditions.

Author: iitsoftware

src/main/java/com/swiftmq/jms/v750/MessageConsumerImpl.java

@@ -33,6 +33,7 @@
 import javax.jms.IllegalStateException;
 import javax.jms.*;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.locks.Lock;
@@ -369,14 +370,16 @@ Message receiveMessage(boolean block, long timeout) throws JMSException {
                             if (timeout == 0) {
                                 waiter.doWait();
                             } else {
-                                long to = timeout;
-                                do {
-                                    long startWait = System.currentTimeMillis();
-                                    waiter.doWait(to);
-                                    long delta = System.currentTimeMillis() - startWait;
-                                    to -= delta;
+                                long deadline = System.nanoTime() + TimeUnit.MILLISECONDS.toNanos(timeout);
+                                long remaining;
+
+                                while ((remaining = deadline - System.nanoTime()) > 0 &&
+                                       messageCache.getSize() == 0 &&
+                                       fillCachePending.get() &&
+                                       !cancelled.get() &&
+                                       !isClosed()) {
+                                    waiter.doWait(TimeUnit.NANOSECONDS.toMillis(remaining));
                                 }
-                                while (to > 0 && messageCache.getSize() == 0 && fillCachePending.get() && !cancelled.get() && !isClosed());
                             }
                         } else {
                             if (fillCachePending.get() && receiveNoWaitFirstCall.get()) {