Batch Publish Async Commit Redux

Author: scottf

README.md

@@ -85,8 +85,8 @@ Run some NATS servers and cause chaos by bringing them up and down.
 
 Utility to publish an atomic batch, a group of up to 1000 messages
 
-**Current Release**: 0.2.1
- **Current Snapshot**: 0.2.2-SNAPSHOT
+**Current Release**: 0.2.2
+ **Current Snapshot**: 0.2.3-SNAPSHOT
 
 [![README](https://img.shields.io/badge/README-blue?style=flat&link=batch-publish/README.md)](batch-publish/README.md)
 ![Artifact](https://img.shields.io/badge/Artifact-io.synadia:batch--publish-00BC8E?labelColor=grey&style=flat)

batch-publish/README.md

@@ -11,8 +11,8 @@ Utility to publish an atomic batch, a group of up to 1000 messages
 
 https://github.com/nats-io/nats-architecture-and-design/blob/main/adr/ADR-50.md
 
-**Current Release**: 0.2.1
- **Current Snapshot**: 0.2.2-SNAPSHOT
+**Current Release**: 0.2.2
+ **Current Snapshot**: 0.2.3-SNAPSHOT
   **Gradle and Maven** `io.synadia:batch-publish`
 [Dependencies Help](https://github.com/synadia-io/orbit.java?tab=readme-ov-file#dependencies) 
 

batch-publish/build.gradle

@@ -13,7 +13,7 @@ plugins {
     id 'signing'
 }
 
-def jarVersion = "0.2.2"
+def jarVersion = "0.2.3"
 group = 'io.synadia'
 
 def isMerge = System.getenv("BUILD_EVENT") == "push"

batch-publish/src/main/java/io/synadia/bp/BatchPublisher.java

@@ -187,19 +187,19 @@ public PublishAck commit(String subject, Headers userHeaders, byte[] data, Batch
         }
     }
 
-    public CompletableFuture<PublishAck> commitAsync(String subject, byte[] data) throws BatchPublishException {
+    public CompletableFuture<PublishAck> commitAsync(String subject, byte[] data) {
         return commitAsync(subject, null, data, null);
     }
 
-    public CompletableFuture<PublishAck> commitAsync(String subject, byte[] data, BatchPublishOptions opts) throws BatchPublishException {
+    public CompletableFuture<PublishAck> commitAsync(String subject, byte[] data, BatchPublishOptions opts) {
         return commitAsync(subject, null, data, opts);
     }
 
-    public CompletableFuture<PublishAck> commitAsync(String subject, Headers userHeaders, byte[] data) throws BatchPublishException {
+    public CompletableFuture<PublishAck> commitAsync(String subject, Headers userHeaders, byte[] data) {
         return commitAsync(subject, userHeaders, data, null);
     }
 
-    public CompletableFuture<PublishAck> commitAsync(String subject, Headers userHeaders, byte[] data, BatchPublishOptions opts) throws BatchPublishException {
+    public CompletableFuture<PublishAck> commitAsync(String subject, Headers userHeaders, byte[] data, BatchPublishOptions opts) {
         return CompletableFuture.supplyAsync(() -> {
             try {
                 return commit(subject, userHeaders, data, opts);