Merge branch 'main' into message-filter-tuning-1

Author: scottf

build.gradle

@@ -37,14 +37,15 @@ repositories {
     maven { url "https://repo1.maven.org/maven2/" }
     maven { url "https://central.sonatype.com/repository/maven-snapshots/" }
     maven { url "https://oss.sonatype.org/content/repositories/releases/" }
+    mavenLocal()
 }
 
 dependencies {
     implementation 'org.bouncycastle:bcprov-lts8on:2.73.8'
     implementation 'org.jspecify:jspecify:1.0.0'
 
     testImplementation 'org.junit.jupiter:junit-jupiter:5.9.0'
-    testImplementation 'io.nats:jnats-server-runner:2.0.0'
+    testImplementation 'io.nats:jnats-server-runner:3.0.1'
     testImplementation 'nl.jqno.equalsverifier:equalsverifier:3.12.3'
 }
 
@@ -97,12 +98,18 @@ test {
 
 javadoc {
     options.overview = 'src/main/javadoc/overview.html' // relative to source root
+    options.memberLevel = JavadocMemberLevel.PUBLIC
     source = sourceSets.main.allJava
     title = "NATS.IO Java API"
-    excludes = ['io/nats/client/impl',
-                'io/nats/examples',
-                "io/nats/client/api/ConsumerCreateRequest.java",
-                "io/nats/client/api/MessageGetRequest.java"
+    excludes = [
+            "io/nats/client/impl",
+            "io/nats/examples",
+            "io/nats/client/api/ConsumerCreateRequest.java",
+            "io/nats/client/api/MessageGetRequest.java",
+            "io/nats/client/api/MessageDeleteRequest.java",
+            "io/nats/client/support/IncomingHeadersProcessor.java",
+            "io/nats/client/support/**",
+            "**/Debug**"
     ]
     classpath = sourceSets.main.runtimeClasspath
     doLast {

src/main/java/io/nats/client/BaseConsumeOptions.java

@@ -31,12 +31,19 @@
  * fetch operate. It is the base class for ConsumeOptions and FetchConsumeOptions.
  */
 public class BaseConsumeOptions implements JsonSerializable {
+    /** constant for default message count */
     public static final int DEFAULT_MESSAGE_COUNT = 500;
+    /** constant for default message count when bytes */
     public static final int DEFAULT_MESSAGE_COUNT_WHEN_BYTES = 1_000_000;
+    /** constant for default threshold percent */
     public static final int DEFAULT_THRESHOLD_PERCENT = 25;
+    /** constant for default expires in millis */
     public static final long DEFAULT_EXPIRES_IN_MILLIS = 30000;
+    /** constant for min expires mills */
     public static final long MIN_EXPIRES_MILLS = 1000;
+    /** constant for max heartbeat millis */
     public static final long MAX_HEARTBEAT_MILLIS = 30000;
+    /** constant for max idle heartbeat percent */
     public static final int MAX_IDLE_HEARTBEAT_PERCENT = 50;
 
     protected final int messages;
@@ -94,34 +101,66 @@ public String toJson() {
 
     protected void subclassSpecificToJson(StringBuilder sb) {}
 
+    /**
+     * Get the expires setting
+     * @return the expires, in milliseconds
+     */
     public long getExpiresInMillis() {
         return expiresIn;
     }
 
+    /**
+     * Get the idle heartbeat value
+     * @return the idle heartbeat in milliseconds
+     */
     public long getIdleHeartbeat() {
         return idleHeartbeat;
     }
 
+    /**
+     * Get the threshold percent setting
+     * @return the threshold percent
+     */
     public int getThresholdPercent() {
         return thresholdPercent;
     }
 
+    /**
+     * Whether to raise status warnings to the error listener
+     * @return true if should raise status warnings
+     */
     public boolean raiseStatusWarnings() {
         return raiseStatusWarnings;
     }
 
+    /**
+     * Get the priority group setting
+     * @return the priority group
+     */
     public String getGroup() {
         return group;
     }
 
+    /**
+     * Get the priority setting
+     * @return the priority
+     */
     public int getPriority() {
         return priority;
     }
 
+    /**
+     * Get the min pending setting
+     * @return the min pending
+     */
     public long getMinPending() {
         return minPending;
     }
 
+    /**
+     * Get the min ack pending setting
+     * @return the min ack pending
+     */
     public long getMinAckPending() {
         return minAckPending;
     }
@@ -143,7 +182,7 @@ protected static abstract class Builder<B, CO> {
          * Initialize values from the json string.
          * @param json the json string to parse
          * @return the builder
-         * @throws JsonParseException if the json is invalid
+         * @throws JsonParseException if there is a problem parsing the json
          */
         public B json(String json) throws JsonParseException {
             return jsonValue(JsonParser.parse(json));