fix: revert default retention to Limits; set WorkQueue in drain test

Default stream retention stays Limits (broker-agnostic default).
The enqueuePopAck_drainsStream test requires WorkQueue semantics so
it now sets the policy explicitly on its own config, matching the
pattern already used by JetStreamMessageBrokerPeekIT.

Assisted-By: Claude Code

Author: sonus21

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

@@ -53,7 +53,7 @@ public static RqueueNatsConfig defaults() {
   public static class StreamDefaults {
     private int replicas = 1;
     private StorageType storage = StorageType.File;
-    private RetentionPolicy retention = RetentionPolicy.WorkQueue;
+    private RetentionPolicy retention = RetentionPolicy.Limits;
     private Duration duplicateWindow = Duration.ofMinutes(2);
     private long maxMsgs = -1;
     private long maxBytes = -1;

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

@@ -26,8 +26,10 @@ class JetStreamMessageBrokerEnqueueAckIT extends AbstractJetStreamIT {
   @Test
   void enqueuePopAck_drainsStream() throws Exception {
     QueueDetail q = mockQueue("eaq-" + System.nanoTime());
+    RqueueNatsConfig cfg = RqueueNatsConfig.defaults();
+    cfg.getStreamDefaults().setRetention(io.nats.client.api.RetentionPolicy.WorkQueue);
     try (JetStreamMessageBroker broker =
-        JetStreamMessageBroker.builder().connection(connection).build()) {
+        JetStreamMessageBroker.builder().connection(connection).config(cfg).build()) {
       List<RqueueMessage> sent = new ArrayList<>();
       for (int i = 0; i < 10; i++) {
         RqueueMessage m =

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

@@ -66,7 +66,7 @@ public static class Connection {
   public static class Stream {
     private int replicas = 1;
     private String storage = "FILE";
-    private String retention = "WORKQUEUE";
+    private String retention = "LIMITS";
     private Duration maxAge = Duration.ofDays(14);
     private long maxBytes = -1;
     private long maxMessages = -1;