From e46c6ded5e48f04221096149dc0ae94c4f3e0c57 Mon Sep 17 00:00:00 2001
From: Scott Fauerbach <scottfauerbach@gmail.com>
Date: Tue, 11 Jun 2024 15:16:32 -0400
Subject: [PATCH] List Subjects start and Java (#202)

---
 docker/java/build.gradle                      |  2 +-
 .../jetstream/list-subjects/java/Main.java    | 85 +++++++++++++++++++
 examples/jetstream/list-subjects/meta.yaml    |  4 +
 examples/jetstream/meta.yaml                  |  3 +
 4 files changed, 93 insertions(+), 1 deletion(-)
 create mode 100644 examples/jetstream/list-subjects/java/Main.java
 create mode 100644 examples/jetstream/list-subjects/meta.yaml

diff --git a/docker/java/build.gradle b/docker/java/build.gradle
index ef523efe..692206ad 100644
--- a/docker/java/build.gradle
+++ b/docker/java/build.gradle
@@ -13,7 +13,7 @@ dependencies {
     implementation 'io.nats:nkeys-java:2.0.1'
     implementation 'io.nats:jnats-json:2.0.0'
     implementation 'io.nats:jwt-java:2.0.0'
-    implementation 'io.nats:jnats:2.17.4'
+    implementation 'io.nats:jnats:2.19.0'
 }
 
 apply plugin: 'java'
diff --git a/examples/jetstream/list-subjects/java/Main.java b/examples/jetstream/list-subjects/java/Main.java
new file mode 100644
index 00000000..f5a1fece
--- /dev/null
+++ b/examples/jetstream/list-subjects/java/Main.java
@@ -0,0 +1,85 @@
+package example;
+
+import io.nats.client.*;
+import io.nats.client.api.*;
+
+import java.io.IOException;
+import java.time.Duration;
+import java.util.Iterator;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+
+public class Main {
+  public static void main(String[] args) {
+    String natsURL = System.getenv("NATS_URL");
+    if (natsURL == null) {
+      natsURL = "nats://127.0.0.1:4222";
+    }
+
+    try (Connection conn = Nats.connect(natsURL)) {
+      JetStreamManagement jsm = conn.jetStreamManagement();
+      JetStream js = jsm.jetStream();
+
+      // Create a stream with a few subjects
+      jsm.addStream(StreamConfiguration.builder()
+          .name("subjects")
+          .subjects("plain", "greater.>", "star.*")
+          .build());
+
+      // ### GetStreamInfo with StreamInfoOptions
+      // Get the subjects via the getStreamInfo call.
+      // Since this is "state" there are no subjects in the state unless
+      // there are messages in the subject.
+      StreamInfo si = jsm.getStreamInfo("subjects", StreamInfoOptions.allSubjects());
+      StreamState state = si.getStreamState();
+      System.out.println("Before publishing any messages, there are 0 subjects: " + state.getSubjectCount());
+
+      // Publish a message
+      js.publish("plain", null);
+
+      si = jsm.getStreamInfo("subjects", StreamInfoOptions.allSubjects());
+      state = si.getStreamState();
+      System.out.println("After publishing a message to a subject, it appears in state:");
+      for (Subject s : state.getSubjects()) {
+        System.out.println("  "  + s);
+      }
+
+      // Publish some more messages, this time against wildcard subjects
+      js.publish("greater.A", null);
+      js.publish("greater.A.B", null);
+      js.publish("greater.A.B.C", null);
+      js.publish("greater.B.B.B", null);
+      js.publish("star.1", null);
+      js.publish("star.2", null);
+
+      si = jsm.getStreamInfo("subjects", StreamInfoOptions.allSubjects());
+      state = si.getStreamState();
+      System.out.println("Wildcard subjects show the actual subject, not the template.");
+      for (Subject s : state.getSubjects()) {
+        System.out.println("  "  + s);
+      }
+
+      // ### Subject Filtering
+      // Instead of allSubjects, you can filter for a specific subject
+      si = jsm.getStreamInfo("subjects", StreamInfoOptions.filterSubjects("greater.>"));
+      state = si.getStreamState();
+      System.out.println("Filtering the subject returns only matching entries ['greater.>']");
+      for (Subject s : state.getSubjects()) {
+        System.out.println("  "  + s);
+      }
+
+      si = jsm.getStreamInfo("subjects", StreamInfoOptions.filterSubjects("greater.A.>"));
+      state = si.getStreamState();
+      System.out.println("Filtering the subject returns only matching entries ['greater.A.>']");
+      for (Subject s : state.getSubjects()) {
+        System.out.println("  "  + s);
+      }
+    }
+    catch (JetStreamApiException | IOException | InterruptedException e) {
+      // * JetStreamApiException: the stream or consumer did not exist
+      // * IOException: problem making the connection
+      // * InterruptedException: thread interruption in the body of the example
+      System.out.println(e);
+    }
+  }
+}
diff --git a/examples/jetstream/list-subjects/meta.yaml b/examples/jetstream/list-subjects/meta.yaml
new file mode 100644
index 00000000..2092689d
--- /dev/null
+++ b/examples/jetstream/list-subjects/meta.yaml
@@ -0,0 +1,4 @@
+title: List subjects for a specific stream
+description: |-
+  All clients have a way to get the list of subjects for any given stream, except it's not completely obvious how to do this.
+  These examples will show you how to get the list of subjects.
diff --git a/examples/jetstream/meta.yaml b/examples/jetstream/meta.yaml
index 7d50e264..733030d1 100644
--- a/examples/jetstream/meta.yaml
+++ b/examples/jetstream/meta.yaml
@@ -14,3 +14,6 @@ examples:
   - queue-push-consumer
   - multi-stream-consumption
   - api-migration
+  - consumer-fetch-messages
+  - partitions
+  - list-subjects