Default NATS prefixes: streams "rqueue-js-", subjects "rqueue.js."

Old defaults were "rqueue-" / "rqueue." which made it hard to tell
JetStream message streams apart from KV-backed buckets (also stored as
streams under "KV_rqueue-…") and from any other Rqueue-shaped resource
sharing the JetStream account. Inserting "-js-" / ".js." into the
defaults is purely operational — it costs nothing at runtime and makes
`nats stream ls` output self-documenting:

    rqueue-js-orders         <- queue stream
    rqueue-js-orders-high    <- priority sub-queue
    rqueue-js-orders-dlq     <- DLQ
    KV_rqueue-jobs           <- KV bucket (unchanged)
    KV_rqueue-locks          <- KV bucket (unchanged)

KV bucket names keep the plain "rqueue-" prefix because their
operator-facing name is the bucket name (`nats kv ls`), not the
underlying stream — and the bucket-vs-stream distinction is already
visible from the `KV_` prefix that JetStream itself adds.

Both defaults are still overridable via
`rqueue.nats.naming.streamPrefix` / `subjectPrefix` for users with their
own naming convention.

Tests that hard-coded the old subject ("rqueue.orders") or stream
("rqueue-failing-dlq", "rqueue-custom-consumer") names in
JetStreamMessageBrokerUnitTest, NatsRetryAndDlqE2EIT, and
NatsConsumerNameOverrideE2EIT are updated to the new defaults.
README's "Streams per queue" table is updated to match.

Assisted-By: Claude Code

Author: sonus21

README.md

@@ -284,17 +284,21 @@ Each registered queue produces **one main stream**, **one DLQ stream** (when
 sub-queue** the queue declares. Only the main queue has a DLQ — priority sub-queues fan out to
 their own streams but share the parent queue's DLQ wiring through `RqueueExecutor`.
 
-| Queue shape                   | Stream count | Names (with default prefixes)                                           |
-|-------------------------------|--------------|-------------------------------------------------------------------------|
-| Plain queue, DLQ on (default) | 2            | `rqueue-<queue>`, `rqueue-<queue>-dlq`                                  |
-| Plain queue, DLQ off          | 1            | `rqueue-<queue>`                                                        |
-| Queue with N priorities, DLQ on | N + 2      | `rqueue-<queue>`, `rqueue-<queue>-<p1>` … `rqueue-<queue>-<pN>`, `rqueue-<queue>-dlq` |
+| Queue shape                   | Stream count | Names (with default prefixes)                                                                  |
+|-------------------------------|--------------|------------------------------------------------------------------------------------------------|
+| Plain queue, DLQ on (default) | 2            | `rqueue-js-<queue>`, `rqueue-js-<queue>-dlq`                                                   |
+| Plain queue, DLQ off          | 1            | `rqueue-js-<queue>`                                                                            |
+| Queue with N priorities, DLQ on | N + 2      | `rqueue-js-<queue>`, `rqueue-js-<queue>-<p1>` … `rqueue-js-<queue>-<pN>`, `rqueue-js-<queue>-dlq` |
 
 The naming scheme is `<streamPrefix><queueName>[-<priority>][<dlqStreamSuffix>]`, configurable via
-`rqueue.nats.naming.streamPrefix` (default `rqueue-`) and `rqueue.nats.naming.dlqSuffix` (default
-`-dlq`). Subjects follow the same shape with `.` separators: `<subjectPrefix><queueName>[.<priority>][<dlqSubjectSuffix>]`.
-Stream defaults (replicas, storage, retention, duplicate window, max msgs/bytes) come from
-`rqueue.nats.stream.*`.
+`rqueue.nats.naming.streamPrefix` (default `rqueue-js-`) and `rqueue.nats.naming.dlqSuffix`
+(default `-dlq`). The `-js-` segment makes Rqueue's message streams easy to distinguish at a
+glance from the JetStream-backed KV buckets below (which keep the plain `rqueue-` prefix because
+that's the operator-facing bucket name, not a stream name) and from anything else sharing the
+JetStream account. Subjects follow the same shape with `.` separators:
+`<subjectPrefix><queueName>[.<priority>][<dlqSubjectSuffix>]` (default subject prefix
+`rqueue.js.`). Stream defaults (replicas, storage, retention, duplicate window, max msgs/bytes)
+come from `rqueue.nats.stream.*`.
 
 ### KV buckets (one set, shared across all queues)
 

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/RqueueNatsConfig.java

@@ -26,8 +26,8 @@
 @Accessors(chain = true)
 public class RqueueNatsConfig {
 
-  private String streamPrefix = "rqueue-";
-  private String subjectPrefix = "rqueue.";
+  private String streamPrefix = "rqueue-js-";
+  private String subjectPrefix = "rqueue.js.";
   private String dlqStreamSuffix = "-dlq";
   private String dlqSubjectSuffix = ".dlq";
 

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

@@ -145,7 +145,7 @@ public void ensureConsumer(
     }
   }
 
-  /** Ensure a DLQ stream exists capturing dead-letter subjects (e.g. "rqueue.*.dlq"). */
+  /** Ensure a DLQ stream exists capturing dead-letter subjects (e.g. "rqueue.js.*.dlq"). */
   public void ensureDlqStream(String dlqStreamName, List<String> dlqSubjects) {
     if (!config.isAutoCreateDlqStream()) {
       return;

rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerUnitTest.java

@@ -22,6 +22,7 @@
 
 import com.github.sonus21.rqueue.core.RqueueMessage;
 import com.github.sonus21.rqueue.listener.QueueDetail;
+import com.github.sonus21.rqueue.nats.js.JetStreamMessageBroker;
 import io.nats.client.Connection;
 import io.nats.client.Dispatcher;
 import io.nats.client.JetStream;
@@ -75,7 +76,7 @@ void enqueue_publishesToPrefixedSubject() throws Exception {
         .thenReturn(mock(PublishAck.class));
     f.broker.enqueue(
         queueNamed("orders"), RqueueMessage.builder().id("m1").message("hi").build());
-    verify(f.js, times(1)).publish(eq("rqueue.orders"), any(Headers.class), any(byte[].class));
+    verify(f.js, times(1)).publish(eq("rqueue.js.orders"), any(Headers.class), any(byte[].class));
   }
 
   @Test
@@ -87,7 +88,7 @@ void enqueueWithPriority_appendsPrioritySuffixToSubject() throws Exception {
         queueNamed("orders"),
         "high",
         RqueueMessage.builder().id("m1").message("hi").build());
-    verify(f.js, times(1)).publish(eq("rqueue.orders.high"), any(Headers.class), any(byte[].class));
+    verify(f.js, times(1)).publish(eq("rqueue.js.orders.high"), any(Headers.class), any(byte[].class));
   }
 
   @Test
@@ -97,7 +98,7 @@ void enqueueWithEmptyPriority_fallsBackToUnsuffixedSubject() throws Exception {
         .thenReturn(mock(PublishAck.class));
     f.broker.enqueue(
         queueNamed("orders"), "", RqueueMessage.builder().id("m1").message("hi").build());
-    verify(f.js, times(1)).publish(eq("rqueue.orders"), any(Headers.class), any(byte[].class));
+    verify(f.js, times(1)).publish(eq("rqueue.js.orders"), any(Headers.class), any(byte[].class));
   }
 
   @Test
@@ -168,7 +169,7 @@ void enqueueReactive_completesWhenPublishFutureCompletes() {
     StepVerifier.create(f.broker.enqueueReactive(
             queueNamed("orders"), RqueueMessage.builder().id("m1").message("hi").build()))
         .verifyComplete();
-    verify(f.js, times(1)).publishAsync(eq("rqueue.orders"), any(Headers.class), any(byte[].class));
+    verify(f.js, times(1)).publishAsync(eq("rqueue.js.orders"), any(Headers.class), any(byte[].class));
   }
 
   @Test

rqueue-spring-boot-starter/src/main/java/com/github/sonus21/rqueue/spring/boot/RqueueNatsProperties.java

@@ -86,8 +86,8 @@ public static class Consumer {
   @Getter
   @Setter
   public static class Naming {
-    private String streamPrefix = "rqueue-";
-    private String subjectPrefix = "rqueue.";
+    private String streamPrefix = "rqueue-js-";
+    private String subjectPrefix = "rqueue.js.";
     private String dlqSuffix = "-dlq";
   }
 }

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/NatsConsumerNameOverrideE2EIT.java

@@ -60,7 +60,7 @@ void overriddenConsumerNameIsRegisteredOnTheStream() throws Exception {
     enqueuer.enqueue("custom-consumer", "hello");
     assertThat(listener.latch.await(20, TimeUnit.SECONDS)).isTrue();
 
-    ConsumerInfo info = jsm.getConsumerInfo("rqueue-custom-consumer", "my-custom-consumer");
+    ConsumerInfo info = jsm.getConsumerInfo("rqueue-js-custom-consumer", "my-custom-consumer");
     assertThat(info).isNotNull();
     assertThat(info.getName()).isEqualTo("my-custom-consumer");
   }

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/integration/NatsRetryAndDlqE2EIT.java

@@ -68,7 +68,7 @@ void exhaustedMessageLandsOnDlqStream() {
     Awaitility.await().atMost(Duration.ofSeconds(60)).until(() -> listener.attempts.get() >= 2);
 
     Awaitility.await().atMost(Duration.ofSeconds(30)).untilAsserted(() -> {
-      StreamInfo dlq = jsm.getStreamInfo("rqueue-failing-dlq");
+      StreamInfo dlq = jsm.getStreamInfo("rqueue-js-failing-dlq");
       assertThat(dlq.getStreamState().getMsgCount()).isGreaterThanOrEqualTo(1);
     });
   }