From 5edf70856e1a422583f7023b09da0dbf6c5ec85b Mon Sep 17 00:00:00 2001 From: scottf Date: Thu, 21 May 2026 09:05:56 -0400 Subject: [PATCH] [New Nats Docs Examples] Normalize examples host [skip claude] --- .../nats/examples/natsIoDoc/BasicsPublish.java | 2 +- .../nats/examples/natsIoDoc/BasicsSubscribe.java | 2 +- .../natsIoDoc/GettingStartedPublish.java | 2 +- .../natsIoDoc/GettingStartedSubscribe.java | 2 +- .../nats/examples/natsIoDoc/JetStreamBasic.java | 2 +- .../examples/natsIoDoc/QueueGroupsBasic.java | 2 +- .../natsIoDoc/QueueGroupsDynamicScaling.java | 2 +- .../natsIoDoc/QueueGroupsMixedSubscribers.java | 2 +- .../natsIoDoc/QueueGroupsRequestReply.java | 2 +- .../examples/natsIoDoc/RequestReplyBasic.java | 2 +- .../natsIoDoc/RequestReplyCalculator.java | 16 ++++++++++++++-- .../examples/natsIoDoc/RequestReplyHeaders.java | 2 +- .../RequestReplyMultipleResponders.java | 2 +- .../natsIoDoc/RequestReplyNoResponders.java | 2 +- .../examples/natsIoDoc/RequestReplyTimeout.java | 2 +- .../examples/natsIoDoc/SubjectsMonitoring.java | 2 +- .../natsIoDoc/SubjectsMultiWildcard.java | 2 +- .../natsIoDoc/SubjectsSingleWildcard.java | 2 +- .../support/WebsocketSupportClassesTests.java | 1 + 19 files changed, 32 insertions(+), 19 deletions(-) diff --git a/examples/src/main/java/io/nats/examples/natsIoDoc/BasicsPublish.java b/examples/src/main/java/io/nats/examples/natsIoDoc/BasicsPublish.java index a04c99626..8ea452559 100644 --- 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 index 2b1294d0f..a1c576d0d 100644 --- 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 index 86d3cc274..68906689b 100644 --- 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 index 886b2cf02..d070065b2 100644 --- 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 index a01825a0c..7e2cbd746 100644 --- 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 index 0c10cdea0..b94378b30 100644 --- 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 index b58b9adc3..ad73c138b 100644 --- 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 workers = new ArrayList(); 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 index 6b9706b98..4261945ce 100644 --- 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 index 89422e10a..35ae41c8b 100644 --- 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 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 index 8a8cbd12e..251498f17 100644 --- 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 index aff6ba4e7..c7eab9cb9 100644 --- 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 index 6a39c2c34..631e73067 100644 --- 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 index fc1a2b361..5ef952c60 100644 --- 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 index 8448dbda5..7b12f71fa 100644 --- 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 index df781425b..672ebf356 100644 --- 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 index 88608bb71..efe51dd90 100644 --- 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 index 8f370429d..e688d35b5 100644 --- 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 index a2b510796..ad1ac9800 100644 --- 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 index d3ee16566..dc176da75 100644 --- 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 {