fix typo

scottf · scottf · commit 235bbd788282 · 2025-06-25T06:55:20.000-04:00
diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java
@@ -1527,7 +1527,7 @@ public Duration RTT() throws IOException {
         pongQueue.add(pongFuture);
         try {
             long time = NatsSystemClock.nanoTime();
-            writer.queueInternalMessage(new ProtocolMessage(PONG_PROTO));
+            writer.queueInternalMessage(new ProtocolMessage(PING_PROTO));
             pongFuture.get(timeout, TimeUnit.MILLISECONDS);
             return Duration.ofNanos(NatsSystemClock.nanoTime() - time);
         }

Original file line number	Diff line number	Diff line change
`@@ -1527,7 +1527,7 @@ public Duration RTT() throws IOException {`
`1527`	`1527`	`pongQueue.add(pongFuture);`
`1528`	`1528`	`try {`
`1529`	`1529`	`long time = NatsSystemClock.nanoTime();`
`1530`		`- writer.queueInternalMessage(new ProtocolMessage(PONG_PROTO));`
	`1530`	`+ writer.queueInternalMessage(new ProtocolMessage(PING_PROTO));`
`1531`	`1531`	`pongFuture.get(timeout, TimeUnit.MILLISECONDS);`
`1532`	`1532`	`return Duration.ofNanos(NatsSystemClock.nanoTime() - time);`
`1533`	`1533`	`}`