nats-io · scottf · May 21, 2026 · May 21, 2026
diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/BasicsPublish.java b/examples/src/main/java/io/nats/examples/natsIoDoc/BasicsPublish.java
@@ -8,7 +8,7 @@
 
 public class BasicsPublish {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
             // NATS-DOC-START
             // Publish a message to the subject "weather.updates"
             byte[] data = "Temperature: 72°F".getBytes(StandardCharsets.UTF_8);

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/BasicsSubscribe.java b/examples/src/main/java/io/nats/examples/natsIoDoc/BasicsSubscribe.java
@@ -10,7 +10,7 @@
 
 public class BasicsSubscribe {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
             // NATS-DOC-START
             // Subscribe to 'weather.updates' synchronously
             Subscription sub = nc.subscribe("weather.updates");

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/GettingStartedPublish.java b/examples/src/main/java/io/nats/examples/natsIoDoc/GettingStartedPublish.java
@@ -9,7 +9,7 @@
 public class GettingStartedPublish {
     // NATS-DOC-START
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
             // Publish a message to the subject "hello"
             byte[] data = "Hello NATS!".getBytes(StandardCharsets.UTF_8);
             nc.publish("hello", data);

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/GettingStartedSubscribe.java b/examples/src/main/java/io/nats/examples/natsIoDoc/GettingStartedSubscribe.java
@@ -8,7 +8,7 @@
 public class GettingStartedSubscribe {
     // NATS-DOC-START
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
             // Asynchronous Subscriber requires a dispatcher
             // Dispatchers can be shared
             Dispatcher d = nc.createDispatcher(msg -> {

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/JetStreamBasic.java b/examples/src/main/java/io/nats/examples/natsIoDoc/JetStreamBasic.java
@@ -7,7 +7,7 @@
 
 public class JetStreamBasic {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Create a stream that captures any subject under `orders.`

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsBasic.java b/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsBasic.java
@@ -11,7 +11,7 @@
 
 public class QueueGroupsBasic {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
             // NATS-DOC-START
             // Worker A
             Dispatcher workerA = nc.createDispatcher(msg -> {

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsDynamicScaling.java b/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsDynamicScaling.java
@@ -28,7 +28,7 @@ public void onMessage(Message msg) throws InterruptedException {
     }
 
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
             List<Worker> workers = new ArrayList<Worker>();
 
             String subject = "tasks";

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsMixedSubscribers.java b/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsMixedSubscribers.java
@@ -9,7 +9,7 @@
 
 public class QueueGroupsMixedSubscribers {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Audit logger - receives all messages

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsRequestReply.java b/examples/src/main/java/io/nats/examples/natsIoDoc/QueueGroupsRequestReply.java
@@ -13,7 +13,7 @@
 
 public class QueueGroupsRequestReply {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             List<Dispatcher> dispatchers = new ArrayList<>();

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyBasic.java b/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyBasic.java
@@ -14,7 +14,7 @@
 
 public class RequestReplyBasic {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Set up a service

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyCalculator.java b/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyCalculator.java
@@ -12,7 +12,7 @@
 
 public class RequestReplyCalculator {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Calculator service
@@ -24,11 +24,14 @@ public static void main(String[] args) {
                         int x = Integer.parseInt(parts[0]);
                         int y = Integer.parseInt(parts[1]);
                         nc.publish(msg.getReplyTo(), ("" + (x + y)).getBytes(StandardCharsets.UTF_8));
+                        return;
                     }
+                    // fall through
                 }
                 catch (Exception e) {
-                    // you could make some other reply here
+                    // fall through
                 }
+                nc.publish(msg.getReplyTo(), "error: invalid input".getBytes(StandardCharsets.UTF_8));
             });
             dCalcAdd.subscribe("calc.add");
 
@@ -50,6 +53,15 @@ public static void main(String[] args) {
             else {
                 System.out.printf("10 + 7 = %s\n", new String(m.getData()));
             }
+
+            // Make a request with a timeout and direct response
+            m = nc.request("calc.add", "10 x".getBytes(StandardCharsets.UTF_8), Duration.ofMillis(500));
+            if (m == null) {
+                System.out.println("3) No Response");
+            }
+            else {
+                System.out.printf("10 + x = %s\n", new String(m.getData()));
+            }
             // NATS-DOC-END
         }
         catch (InterruptedException e) {

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyHeaders.java b/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyHeaders.java
@@ -11,7 +11,7 @@
 
 public class RequestReplyHeaders {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Header Aware service

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyMultipleResponders.java b/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyMultipleResponders.java
@@ -12,7 +12,7 @@
 
 public class RequestReplyMultipleResponders {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Set up 2 instances of the service

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyNoResponders.java b/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyNoResponders.java
@@ -13,7 +13,7 @@ public static void main(String[] args) {
         // NATS-DOC-START
         // You must specify the reportNoResponders() connect option
         Options options = Options.builder()
-            .server("demo.nats.io")
+            .server("nats://localhost:4222")
             .reportNoResponders()
             .build();
         try (Connection nc = Nats.connect(options)) {

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyTimeout.java b/examples/src/main/java/io/nats/examples/natsIoDoc/RequestReplyTimeout.java
@@ -10,7 +10,7 @@
 
 public class RequestReplyTimeout {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Make a request expecting a future

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/SubjectsMonitoring.java b/examples/src/main/java/io/nats/examples/natsIoDoc/SubjectsMonitoring.java
@@ -10,7 +10,7 @@
 
 public class SubjectsMonitoring {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Asynchronous subscribers require a dispatcher

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/SubjectsMultiWildcard.java b/examples/src/main/java/io/nats/examples/natsIoDoc/SubjectsMultiWildcard.java
@@ -9,7 +9,7 @@
 public class SubjectsMultiWildcard {
     // NATS-DOC-START
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Subscribe to all alarms

diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/SubjectsSingleWildcard.java b/examples/src/main/java/io/nats/examples/natsIoDoc/SubjectsSingleWildcard.java
@@ -8,7 +8,7 @@
 
 public class SubjectsSingleWildcard {
     public static void main(String[] args) {
-        try (Connection nc = Nats.connect("demo.nats.io")) {
+        try (Connection nc = Nats.connect("nats://localhost:4222")) {
 
             // NATS-DOC-START
             // Subscribe to the shipped orders

diff --git a/src/test/java/io/nats/client/support/WebsocketSupportClassesTests.java b/src/test/java/io/nats/client/support/WebsocketSupportClassesTests.java
@@ -307,6 +307,7 @@ private void testWithWriter(OutputStreamWrite writer, String msgStartsWith) thro
                 }
             }
             catch (IllegalStateException ise) {
+                System.out.println(msgStartsWith + " | " + ise);
                 assertTrue(ise.getMessage().startsWith(msgStartsWith));
             }
             try {
-Original file line number
+Diff line change
@@ Expand Up @@
                     }
                 }
                 catch (IllegalStateException ise) {
+                    System.out.println(msgStartsWith + " | " + ise);
                     assertTrue(ise.getMessage().startsWith(msgStartsWith));
                 }
                 try {
@@ Expand Down @@