Apply Palantir Java Format

Assisted-By: Claude Code

Author: sonus21

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/internal/NatsProvisioner.java

@@ -171,7 +171,10 @@ private ConsumerInfo safeGetConsumerInfo(String streamName, String consumerName)
     try {
       return jsm.getConsumerInfo(streamName, consumerName);
     } catch (JetStreamApiException e) {
-      if (e.getApiErrorCode() == 10014 || e.getErrorCode() == 404) {
+      // 10014 = consumer not found, 10059 = stream not found (stream hasn't been created yet).
+      // Both cases mean "consumer doesn't exist"; callers should create the consumer (and ensure
+      // the stream) rather than receiving an exception here.
+      if (e.getApiErrorCode() == 10014 || e.getApiErrorCode() == 10059 || e.getErrorCode() == 404) {
         return null;
       }
       throw e;

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js/NatsStreamValidator.java

@@ -109,12 +109,21 @@ public void onApplicationEvent(RqueueBootstrapEvent event) {
       }
     }
     if (!failures.isEmpty()) {
+      String hint = config.isAutoCreateStreams()
+          ? "Stream creation failed — verify NATS is running with JetStream enabled"
+              + " (start the server with `nats-server -js`) and that the account has"
+              + " `add_stream` permission."
+          : "With rqueue.nats.auto-create-streams=false every required stream must exist"
+              + " before the application starts. Run `nats stream add` for each missing"
+              + " stream or set rqueue.nats.auto-create-streams=true to let rqueue create"
+              + " them automatically.";
       throw new IllegalStateException("NATS JetStream provisioning failed for "
           + failures.size()
           + " of "
           + total
-          + " stream(s) at startup. With rqueue.nats.autoCreateStreams=false, every required"
-          + " stream must exist before the application starts. Failed streams:\n"
+          + " stream(s) at startup. "
+          + hint
+          + " Failed streams:\n"
           + "  - "
           + String.join("\n  - ", failures));
     }
@@ -129,7 +138,7 @@ private int tryEnsure(List<String> failures, String streamName, String subject)
       provisioner.ensureStream(streamName, List.of(subject));
       return 1;
     } catch (RqueueNatsException e) {
-      failures.add(streamName + " (subject " + subject + "): " + e.getMessage());
+      failures.add(streamName + " (subject " + subject + "): " + rootCause(e));
       return 1;
     }
   }
@@ -139,8 +148,18 @@ private int tryEnsureDlq(List<String> failures, String dlqStream, String dlqSubj
       provisioner.ensureDlqStream(dlqStream, List.of(dlqSubject));
       return 1;
     } catch (RqueueNatsException e) {
-      failures.add(dlqStream + " (DLQ subject " + dlqSubject + "): " + e.getMessage());
+      failures.add(dlqStream + " (DLQ subject " + dlqSubject + "): " + rootCause(e));
       return 1;
     }
   }
+
+  /** Returns the deepest non-null message in the cause chain for diagnostics. */
+  private static String rootCause(Throwable t) {
+    Throwable cause = t;
+    while (cause.getCause() != null) {
+      cause = cause.getCause();
+    }
+    String msg = cause.getMessage();
+    return (msg != null && !msg.isEmpty()) ? msg : cause.getClass().getSimpleName();
+  }
 }

rqueue-spring-boot-nats-example/src/main/java/com/github/sonus21/rqueue/example/RQueueNatApplication.java

@@ -30,13 +30,13 @@
  * pluggable-backend split.
  */
 @SpringBootApplication
-public class RQueueApplication {
+public class RQueueNatApplication {
 
   @Value("${workers.count:3}")
   private int workersCount;
 
   public static void main(String[] args) {
-    SpringApplication.run(RQueueApplication.class, args);
+    SpringApplication.run(RQueueNatApplication.class, args);
   }
 
   @Bean

rqueue-spring-boot-nats-example/src/main/resources/application.properties

@@ -19,6 +19,7 @@
 # enabled server. Everything else (queue names, listeners, controller) is
 # identical to the redis example, which is the point of the pluggable split.
 rqueue.backend=nats
+server.port=9090
 
 # NATS / JetStream connection. Default is the public-binding nats-server URL
 # from a vanilla `nats-server -js` install. For docker, point at the running