[Fix] Simplified Ordered Consumer - Getting name early can cause NPE

src/examples/java/io/nats/examples/chaosTestApp/ChaosTestApp.java

@@ -38,18 +38,18 @@ public class ChaosTestApp {
             + " --stream jchaos-stream"
             + " --subject jchaos-subject"
 //            + " --runtime 3600 // 1 hour in seconds
-            + " --screen left"
+//            + " --screen left"
 //            + " --work"
             + " --create"
 //            + " --r3"
             + " --publish"
             + " --pubjitter 30"
 //            + " --simple ephemeral,100,5000"
             + " --simple ordered 100 5000"
-            + " --simple durable 100 5000" // space or commas work, the parser figures it out
-            + " --fetch durable,100,5000"
-            + " --push ordered"
-            + " --push durable"
+//            + " --simple durable 100 5000" // space or commas work, the parser figures it out
+//            + " --fetch durable,100,5000"
+//            + " --push ordered"
+//            + " --push durable"
 //            + " --logdir c:\\temp"
     ).split(" ");
 

src/examples/java/io/nats/examples/chaosTestApp/support/CommandLine.java

@@ -32,7 +32,7 @@ private void usage() {
             "----------------------------------------------------------------------------------------------------\n" +
             "--servers <natsServerUrl>[,<natsServerUrl>]*\n" +
             "  * i.e. --servers nats://localhost:4000,nats://localhost:4001,nats://localhost:4002\n" +
-            "  * not supplied uses \"ats://localhost:4222\"\n" +
+            "  * not supplied uses \"nats://localhost:4222\"\n" +
             "--stream <stream name>\n" +
             "  * not supplied uses \"app-stream\"\n" +
             "--subject <subject>\n" +

src/examples/java/io/nats/examples/jetstream/NatsJsPushSubOrdered.java

@@ -44,6 +44,7 @@ public class NatsJsPushSubOrdered {
     public static void main(String[] args) {
         Options options = Options.builder()
             .server(SERVER)
+            .connectionListener((c, e) -> System.out.println(e.name()))
             .errorListener(new ErrorListenerConsoleImpl())
             .build();
         try (Connection nc = Nats.connect(options)) {

src/examples/java/io/nats/examples/jetstream/simple/OrderedMessageConsumerExample.java

@@ -44,6 +44,7 @@ public class OrderedMessageConsumerExample {
     public static void main(String[] args) {
         Options options = Options.builder()
             .server(SERVER)
+            .connectionListener((c, e) -> System.out.println(e.name()))
             .errorListener(new ErrorListenerConsoleImpl())
             .build();
         try (Connection nc = Nats.connect(options)) {

src/main/java/io/nats/client/impl/NatsMessageConsumerBase.java

@@ -43,6 +43,7 @@ void setConsumerName(String consumerName) {
 
     void initSub(NatsJetStreamPullSubscription sub) {
         this.sub = sub;
+        this.consumerName = sub.getConsumerName();
         pmm = (PullMessageManager)sub.manager;
     }
 
@@ -65,7 +66,7 @@ public boolean isFinished() {
      */
     @Override
     public String getConsumerName() {
-        if (consumerName == null) {
+        if (consumerName == null && cachedConsumerInfo != null) {
             consumerName = cachedConsumerInfo.getName();
         }
         return consumerName;