diff --git a/.github/workflows/counter-main.yml b/.github/workflows/counter-main.yml
new file mode 100644
index 0000000..02a7f0d
--- /dev/null
+++ b/.github/workflows/counter-main.yml
@@ -0,0 +1,47 @@
+name: Counter Main Snapshot
+
+on:
+ push:
+ branches:
+ - main
+ paths:
+ - 'counter/**'
+
+jobs:
+ build:
+ runs-on: ubuntu-latest
+ env:
+ BUILD_EVENT: ${{ github.event_name }}
+ OSSRH_USERNAME: ${{ secrets.OSSRH_USERNAME }}
+ OSSRH_PASSWORD: ${{ secrets.OSSRH_TOKEN }}
+ SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
+ SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
+ SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
+ steps:
+ - name: Set up JDK 8
+ uses: actions/setup-java@v3
+ with:
+ java-version: '8'
+ distribution: 'adopt'
+ - name: Install Nats Server
+ run: |
+ curl -sf https://binaries.nats.dev/nats-io/nats-server/v2@main | PREFIX=. sh
+ sudo mv nats-server /usr/local/bin
+ nats-server -v
+ - name: Check out code
+ uses: actions/checkout@v3
+ - name: Compile and Test
+ run: |
+ pushd counter
+ chmod +x gradlew && ./gradlew clean test
+ popd
+ - name: Verify Javadoc
+ run: |
+ pushd counter
+ ./gradlew javadoc
+ popd
+ - name: Publish Snapshot
+ run: |
+ pushd counter
+ ./gradlew -i publishToSonatype
+ popd
diff --git a/.github/workflows/counter-pr.yml b/.github/workflows/counter-pr.yml
new file mode 100644
index 0000000..bc2c9f1
--- /dev/null
+++ b/.github/workflows/counter-pr.yml
@@ -0,0 +1,41 @@
+name: Counter Pull Request
+
+on:
+ pull_request:
+ types: [opened, synchronize, reopened]
+ paths:
+ - 'counter/**'
+
+jobs:
+ build:
+ runs-on: ubuntu-latest
+ env:
+ BUILD_EVENT: ${{ github.event_name }}
+ OSSRH_USERNAME: ${{ secrets.OSSRH_USERNAME }}
+ OSSRH_PASSWORD: ${{ secrets.OSSRH_TOKEN }}
+ SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
+ SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
+ SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
+ steps:
+ - name: Set up JDK 8
+ uses: actions/setup-java@v3
+ with:
+ java-version: '8'
+ distribution: 'adopt'
+ - name: Install Nats Server
+ run: |
+ curl -sf https://binaries.nats.dev/nats-io/nats-server/v2@main | PREFIX=. sh
+ sudo mv nats-server /usr/local/bin
+ nats-server -v
+ - name: Check out code
+ uses: actions/checkout@v3
+ - name: Compile and Test
+ run: |
+ pushd counter
+ chmod +x gradlew && ./gradlew clean test
+ popd
+ - name: Verify Javadoc
+ run: |
+ pushd counter
+ ./gradlew javadoc
+ popd
diff --git a/.github/workflows/counter-release.yml b/.github/workflows/counter-release.yml
new file mode 100644
index 0000000..912c303
--- /dev/null
+++ b/.github/workflows/counter-release.yml
@@ -0,0 +1,39 @@
+name: Counter Release
+
+on:
+ push:
+ tags: [ 'counter/*' ]
+
+jobs:
+ build:
+ runs-on: ubuntu-latest
+ env:
+ BUILD_EVENT: "release"
+ OSSRH_USERNAME: ${{ secrets.OSSRH_USERNAME }}
+ OSSRH_PASSWORD: ${{ secrets.OSSRH_TOKEN }}
+ SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
+ SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
+ SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
+ steps:
+ - name: Set up JDK 8
+ uses: actions/setup-java@v3
+ with:
+ java-version: '8'
+ distribution: 'adopt'
+ - name: Install Nats Server
+ run: |
+ curl -sf https://binaries.nats.dev/nats-io/nats-server/v2@main | PREFIX=. sh
+ sudo mv nats-server /usr/local/bin
+ nats-server -v
+ - name: Check out code
+ uses: actions/checkout@v3
+ - name: Compile and Test
+ run: |
+ pushd counter
+ chmod +x gradlew && ./gradlew clean test
+ popd
+ - name: Verify, Sign and Publish Release
+ run: |
+ pushd counter
+ ./gradlew -i signArchives signMavenJavaPublication publishToSonatype closeAndReleaseSonatypeStagingRepository
+ popd
diff --git a/.github/workflows/cr-main.yml b/.github/workflows/cr-main.yml
index a162f89..babbd7f 100644
--- a/.github/workflows/cr-main.yml
+++ b/.github/workflows/cr-main.yml
@@ -7,9 +7,6 @@ on:
paths:
- 'chaos-runner/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -20,7 +17,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/cr-pr.yml b/.github/workflows/cr-pr.yml
index 337c884..9d59f24 100644
--- a/.github/workflows/cr-pr.yml
+++ b/.github/workflows/cr-pr.yml
@@ -6,9 +6,6 @@ on:
paths:
- 'chaos-runner/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -19,7 +16,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/cr-release.yml b/.github/workflows/cr-release.yml
index 47f7cdd..a01b18a 100644
--- a/.github/workflows/cr-release.yml
+++ b/.github/workflows/cr-release.yml
@@ -4,9 +4,6 @@ on:
push:
tags: [ 'cr/*' ]
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -17,7 +14,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/db-main.yml b/.github/workflows/db-main.yml
index 690cbd0..8ba10a6 100644
--- a/.github/workflows/db-main.yml
+++ b/.github/workflows/db-main.yml
@@ -7,9 +7,6 @@ on:
paths:
- 'direct-batch/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -20,7 +17,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/db-pr.yml b/.github/workflows/db-pr.yml
index 19c54c8..92f1b62 100644
--- a/.github/workflows/db-pr.yml
+++ b/.github/workflows/db-pr.yml
@@ -6,9 +6,6 @@ on:
paths:
- 'direct-batch/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -19,7 +16,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/db-release.yml b/.github/workflows/db-release.yml
index 0d2fb92..b1db120 100644
--- a/.github/workflows/db-release.yml
+++ b/.github/workflows/db-release.yml
@@ -4,9 +4,6 @@ on:
push:
tags: [ 'db/*' ]
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -17,7 +14,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/ekv-main.yml b/.github/workflows/ekv-main.yml
index 26b6c59..30c4c98 100644
--- a/.github/workflows/ekv-main.yml
+++ b/.github/workflows/ekv-main.yml
@@ -7,9 +7,6 @@ on:
paths:
- 'encoded-kv/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -20,7 +17,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/ekv-pr.yml b/.github/workflows/ekv-pr.yml
index 15e0e9b..9b87465 100644
--- a/.github/workflows/ekv-pr.yml
+++ b/.github/workflows/ekv-pr.yml
@@ -6,9 +6,6 @@ on:
paths:
- 'encoded-kv/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -19,7 +16,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/ekv-release.yml b/.github/workflows/ekv-release.yml
index 699bee7..2cc62dc 100644
--- a/.github/workflows/ekv-release.yml
+++ b/.github/workflows/ekv-release.yml
@@ -4,9 +4,6 @@ on:
push:
tags: [ 'ekv/*' ]
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -17,7 +14,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/pubx-main.yml b/.github/workflows/pubx-main.yml
index 4de4f09..dfe93d7 100644
--- a/.github/workflows/pubx-main.yml
+++ b/.github/workflows/pubx-main.yml
@@ -7,9 +7,6 @@ on:
paths:
- 'js-publish-extensions/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -20,7 +17,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/pubx-pr.yml b/.github/workflows/pubx-pr.yml
index d04ccf0..b9c9a82 100644
--- a/.github/workflows/pubx-pr.yml
+++ b/.github/workflows/pubx-pr.yml
@@ -6,9 +6,6 @@ on:
paths:
- 'js-publish-extensions/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -19,7 +16,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/pubx-release.yml b/.github/workflows/pubx-release.yml
index 8f5c08e..efdf855 100644
--- a/.github/workflows/pubx-release.yml
+++ b/.github/workflows/pubx-release.yml
@@ -4,9 +4,6 @@ on:
push:
tags: [ 'pubx/*' ]
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -17,7 +14,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/retrier-main.yml b/.github/workflows/retrier-main.yml
index ef3df39..7d51520 100644
--- a/.github/workflows/retrier-main.yml
+++ b/.github/workflows/retrier-main.yml
@@ -7,9 +7,6 @@ on:
paths:
- 'retrier/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -20,7 +17,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/retrier-pr.yml b/.github/workflows/retrier-pr.yml
index 79b891f..31beed7 100644
--- a/.github/workflows/retrier-pr.yml
+++ b/.github/workflows/retrier-pr.yml
@@ -6,9 +6,6 @@ on:
paths:
- 'retrier/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -19,7 +16,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/retrier-release.yml b/.github/workflows/retrier-release.yml
index 42a54ee..853e04c 100644
--- a/.github/workflows/retrier-release.yml
+++ b/.github/workflows/retrier-release.yml
@@ -4,9 +4,6 @@ on:
push:
tags: [ 'retrier/*' ]
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -17,7 +14,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/rm-main.yml b/.github/workflows/rm-main.yml
index 7d1b0b8..c9e62ea 100644
--- a/.github/workflows/rm-main.yml
+++ b/.github/workflows/rm-main.yml
@@ -7,9 +7,6 @@ on:
paths:
- 'request-many/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -20,7 +17,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/rm-pr.yml b/.github/workflows/rm-pr.yml
index 8527a70..5938636 100644
--- a/.github/workflows/rm-pr.yml
+++ b/.github/workflows/rm-pr.yml
@@ -6,9 +6,6 @@ on:
paths:
- 'request-many/**'
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -19,7 +16,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/.github/workflows/rm-release.yml b/.github/workflows/rm-release.yml
index e6ab31c..d186d36 100644
--- a/.github/workflows/rm-release.yml
+++ b/.github/workflows/rm-release.yml
@@ -4,9 +4,6 @@ on:
push:
tags: [ 'rm/*' ]
-env:
- GODEBUG: x509sha1=1
-
jobs:
build:
runs-on: ubuntu-latest
@@ -17,7 +14,6 @@ jobs:
SIGNING_KEY_ID: ${{ secrets.SIGNING_KEY_ID }}
SIGNING_KEY: ${{ secrets.SIGNING_KEY }}
SIGNING_PASSWORD: ${{ secrets.SIGNING_PASSWORD }}
- GODEBUG: x509sha1=1
steps:
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git a/chaos-runner/build.gradle b/chaos-runner/build.gradle
index 9a93d45..a36b7a1 100644
--- a/chaos-runner/build.gradle
+++ b/chaos-runner/build.gradle
@@ -40,7 +40,7 @@ repositories {
dependencies {
implementation 'io.nats:jnats-server-runner:2.0.2'
- implementation 'io.nats:jnats:2.21.4' // this is only for the example and the uber jar won't include it
+ implementation 'io.nats:jnats:2.21.5' // this is only for the example and the uber jar won't include it
testImplementation 'commons-codec:commons-codec:1.18.0'
testImplementation 'org.junit.jupiter:junit-jupiter:5.9.0'
diff --git a/counter/.gitignore b/counter/.gitignore
new file mode 100644
index 0000000..b3e2ca5
--- /dev/null
+++ b/counter/.gitignore
@@ -0,0 +1,77 @@
+
+# NATS stuff #
+##############
+gnatsd.log
+*.csv
+
+# Compiled source #
+###################
+*.com
+*.class
+*.dll
+*.exe
+*.o
+*.so
+/bin
+
+# Packages #
+############
+*.7z
+*.dmg
+*.gz
+*.iso
+*.rar
+*.tar
+*.zip
+
+# Logs and databases #
+######################
+*.log
+
+# OS generated files #
+######################
+.DS_Store*
+ehthumbs.db
+Icon?
+Thumbs.db
+
+# Editor Files #
+################
+*~
+*.swp
+.sts4-cache/*
+
+# Gradle Files #
+################
+.gradle
+.m2
+
+# Build output directies
+/target
+*/target
+/build
+*/build
+
+# IntelliJ specific files/directories
+out
+.idea
+*.ipr
+*.iws
+*.iml
+atlassian-ide-plugin.xml
+
+# Eclipse specific files/directories
+.classpath
+.project
+.settings
+.metadata
+
+# NetBeans specific files/directories
+.nbattrs
+
+# VSCode
+.vscode/
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+/target/
diff --git a/counter/LICENSE b/counter/LICENSE
new file mode 100644
index 0000000..261eeb9
--- /dev/null
+++ b/counter/LICENSE
@@ -0,0 +1,201 @@
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
diff --git a/counter/NOTICE b/counter/NOTICE
new file mode 100644
index 0000000..ff3c8b4
--- /dev/null
+++ b/counter/NOTICE
@@ -0,0 +1,5 @@
+Orbit Java
+Copyright (c) 2024-2025 Synadia Communications Inc. All Rights Reserved.
+
+This product includes software developed at
+Synadia Communications Inc.
\ No newline at end of file
diff --git a/counter/README.md b/counter/README.md
new file mode 100644
index 0000000..fb6ac8b
--- /dev/null
+++ b/counter/README.md
@@ -0,0 +1,20 @@
+ 
+
+# JetStream Distributed Counter CRDT
+
+https://github.com/nats-io/nats-architecture-and-design/blob/main/adr/ADR-49.md
+
+
+**Current Release**: N/A
+ **Current Snapshot**: 0.1.0-SNAPSHOT
+ **Gradle and Maven** `io.synadia:counter`
+[Dependencies Help](https://github.com/synadia-io/orbit.java?tab=readme-ov-file#dependencies)
+
+
+[](https://www.apache.org/licenses/LICENSE-2.0)
+[](https://maven-badges.herokuapp.com/maven-central/io.synadia/counter)
+[](https://javadoc.io/doc/io.synadia/counter)
+
+---
+Copyright (c) 2025 Synadia Communications Inc. All Rights Reserved.
+See [LICENSE](LICENSE) and [NOTICE](NOTICE) file for details.
diff --git a/counter/build.gradle b/counter/build.gradle
new file mode 100644
index 0000000..8bbb6ff
--- /dev/null
+++ b/counter/build.gradle
@@ -0,0 +1,207 @@
+import aQute.bnd.gradle.Bundle
+import org.gradle.internal.os.OperatingSystem
+
+plugins {
+ id 'java'
+ id 'java-library'
+ id 'maven-publish'
+ id 'jacoco'
+ id 'com.github.kt3k.coveralls' version '2.12.0'
+ id 'biz.aQute.bnd.builder' version '5.1.2'
+ id "org.gradle.test-retry" version "1.1.9"
+ id 'io.github.gradle-nexus.publish-plugin' version '1.1.0'
+ id 'signing'
+}
+
+def jarVersion = "0.0.1"
+group = 'io.synadia'
+
+def isMerge = System.getenv("BUILD_EVENT") == "push"
+def isRelease = System.getenv("BUILD_EVENT") == "release"
+
+// version is the variable the build actually uses.
+version = isRelease ? jarVersion : jarVersion + "-SNAPSHOT"
+
+java {
+ sourceCompatibility = JavaVersion.VERSION_1_8
+ targetCompatibility = JavaVersion.VERSION_1_8
+}
+
+repositories {
+ mavenCentral()
+ maven {
+ url "https://repo1.maven.org/maven2/"
+ }
+ maven {
+ url "https://central.sonatype.com/repository/maven-snapshots/"
+ }
+}
+
+dependencies {
+ implementation 'io.nats:jnats:2.22.0.2_12-SNAPSHOT'
+ implementation 'io.synadia:direct-batch:0.1.2'
+ implementation 'org.jspecify:jspecify:1.0.0'
+
+ testImplementation 'commons-codec:commons-codec:1.18.0'
+ testImplementation 'io.nats:jnats-server-runner:1.2.8'
+ testImplementation 'org.junit.jupiter:junit-jupiter:5.9.0'
+ testImplementation 'com.github.stefanbirkner:system-lambda:1.2.1'
+ testImplementation 'nl.jqno.equalsverifier:equalsverifier:3.12.3'
+}
+
+sourceSets {
+ main {
+ java {
+ srcDirs = ['src/main/java','src/examples/java']
+ }
+ }
+ test {
+ java {
+ srcDirs = ['src/test/java']
+ }
+ }
+}
+
+tasks.register('bundle', Bundle) {
+ from sourceSets.main.output
+ exclude("io/synadia/examples/**")
+}
+
+jar {
+ manifest {
+ attributes('Automatic-Module-Name': 'io.synadia.counter')
+ }
+ bnd (['Implementation-Title': 'JetStream Distributed Counter',
+ 'Implementation-Version': jarVersion,
+ 'Implementation-Vendor': 'synadia.io']
+ )
+ exclude("io/synadia/examples/**")
+}
+
+test {
+ // Use junit platform for unit tests
+ useJUnitPlatform()
+}
+
+javadoc {
+ options.overview = 'src/main/javadoc/overview.html' // relative to source root
+ source = sourceSets.main.allJava
+ title = "Synadia Communications Inc. JetStream Distributed Counter"
+ classpath = sourceSets.main.runtimeClasspath
+ doLast {
+ if (!OperatingSystem.current().isWindows()) {
+ exec {
+ println "Updating favicon on all html files"
+ workingDir 'build/docs/javadoc'
+ // Only on linux, mac at this point
+ commandLine 'find', '.', '-name', '*.html', '-exec', 'sed', '-i', '-e', 's###', '{}', ';'
+ }
+ copy {
+ println "Copying images to javadoc folder"
+ from 'src/main/javadoc/images'
+ into 'build/docs/javadoc'
+ }
+ }
+ }
+}
+
+tasks.register('examplesJar', Jar) {
+ archiveClassifier.set('examples')
+ manifest {
+ attributes('Implementation-Title': 'JetStream Distributed Counters',
+ 'Implementation-Version': jarVersion,
+ 'Implementation-Vendor': 'synadia.io')
+ }
+ from(sourceSets.main.output) {
+ include "io/synadia/examples/**"
+ }
+}
+
+tasks.register('javadocJar', Jar) {
+ archiveClassifier.set('javadoc')
+ from javadoc
+}
+
+tasks.register('sourcesJar', Jar) {
+ archiveClassifier.set('sources')
+ from sourceSets.main.allSource
+}
+
+jacoco {
+ toolVersion = "0.8.6"
+}
+
+jacocoTestReport {
+ reports {
+ xml.enabled = true // coveralls plugin depends on xml format report
+ html.enabled = true
+ }
+ afterEvaluate { // only report on main library not examples
+ classDirectories.setFrom(files(classDirectories.files.collect {
+ fileTree(dir: it,
+ exclude: ['**/examples**'])
+ }))
+ }
+}
+
+artifacts {
+ archives javadocJar, sourcesJar, examplesJar
+}
+
+nexusPublishing {
+ repositories {
+ sonatype {
+ nexusUrl.set(uri("https://ossrh-staging-api.central.sonatype.com/service/local/"))
+ snapshotRepositoryUrl.set(uri("https://central.sonatype.com/repository/maven-snapshots/"))
+ username = System.getenv('OSSRH_USERNAME')
+ password = System.getenv('OSSRH_PASSWORD')
+ }
+ }
+}
+
+publishing {
+ publications {
+ mavenJava(MavenPublication) {
+ from components.java
+ artifact sourcesJar
+ artifact examplesJar
+ artifact javadocJar
+ pom {
+ name = 'counter'
+ packaging = 'jar'
+ groupId = group
+ artifactId = archivesBaseName
+ description = 'Synadia Communications Inc. JetStream Distributed Counters'
+ url = 'https://github.com/synadia-io/orbit.java'
+ licenses {
+ license {
+ name = 'The Apache License, Version 2.0'
+ url = 'http://www.apache.org/licenses/LICENSE-2.0.txt'
+ }
+ }
+ developers {
+ developer {
+ id = "synadia"
+ name = "Synadia"
+ email = "info@synadia.com"
+ url = "https://synadia.io"
+ }
+ }
+ scm {
+ url = 'https://github.com/synadia-io/orbit.java'
+ }
+ }
+ }
+ }
+}
+
+if (isRelease) {
+ signing {
+ def signingKeyId = System.getenv('SIGNING_KEY_ID')
+ def signingKey = System.getenv('SIGNING_KEY')
+ def signingPassword = System.getenv('SIGNING_PASSWORD')
+ useInMemoryPgpKeys(signingKeyId, signingKey, signingPassword)
+ sign configurations.archives
+ sign publishing.publications.mavenJava
+ }
+}
\ No newline at end of file
diff --git a/counter/gradle/wrapper/gradle-wrapper.jar b/counter/gradle/wrapper/gradle-wrapper.jar
new file mode 100644
index 0000000..490fda8
Binary files /dev/null and b/counter/gradle/wrapper/gradle-wrapper.jar differ
diff --git a/counter/gradle/wrapper/gradle-wrapper.properties b/counter/gradle/wrapper/gradle-wrapper.properties
new file mode 100644
index 0000000..442d913
--- /dev/null
+++ b/counter/gradle/wrapper/gradle-wrapper.properties
@@ -0,0 +1,5 @@
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.8.3-bin.zip
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
diff --git a/counter/gradlew b/counter/gradlew
new file mode 100644
index 0000000..2fe81a7
--- /dev/null
+++ b/counter/gradlew
@@ -0,0 +1,183 @@
+#!/usr/bin/env sh
+
+#
+# Copyright 2015 the original author or authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##############################################################################
+##
+## Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+ ls=`ls -ld "$PRG"`
+ link=`expr "$ls" : '.*-> \(.*\)$'`
+ if expr "$link" : '/.*' > /dev/null; then
+ PRG="$link"
+ else
+ PRG=`dirname "$PRG"`"/$link"
+ fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn () {
+ echo "$*"
+}
+
+die () {
+ echo
+ echo "$*"
+ echo
+ exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+ CYGWIN* )
+ cygwin=true
+ ;;
+ Darwin* )
+ darwin=true
+ ;;
+ MINGW* )
+ msys=true
+ ;;
+ NONSTOP* )
+ nonstop=true
+ ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+ if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+ # IBM's JDK on AIX uses strange locations for the executables
+ JAVACMD="$JAVA_HOME/jre/sh/java"
+ else
+ JAVACMD="$JAVA_HOME/bin/java"
+ fi
+ if [ ! -x "$JAVACMD" ] ; then
+ die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+ fi
+else
+ JAVACMD="java"
+ which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+ MAX_FD_LIMIT=`ulimit -H -n`
+ if [ $? -eq 0 ] ; then
+ if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+ MAX_FD="$MAX_FD_LIMIT"
+ fi
+ ulimit -n $MAX_FD
+ if [ $? -ne 0 ] ; then
+ warn "Could not set maximum file descriptor limit: $MAX_FD"
+ fi
+ else
+ warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+ fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+ GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if [ "$cygwin" = "true" -o "$msys" = "true" ] ; then
+ APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+ CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+ JAVACMD=`cygpath --unix "$JAVACMD"`
+
+ # We build the pattern for arguments to be converted via cygpath
+ ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+ SEP=""
+ for dir in $ROOTDIRSRAW ; do
+ ROOTDIRS="$ROOTDIRS$SEP$dir"
+ SEP="|"
+ done
+ OURCYGPATTERN="(^($ROOTDIRS))"
+ # Add a user-defined pattern to the cygpath arguments
+ if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+ OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+ fi
+ # Now convert the arguments - kludge to limit ourselves to /bin/sh
+ i=0
+ for arg in "$@" ; do
+ CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+ CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option
+
+ if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition
+ eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+ else
+ eval `echo args$i`="\"$arg\""
+ fi
+ i=`expr $i + 1`
+ done
+ case $i in
+ 0) set -- ;;
+ 1) set -- "$args0" ;;
+ 2) set -- "$args0" "$args1" ;;
+ 3) set -- "$args0" "$args1" "$args2" ;;
+ 4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+ 5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+ 6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+ 7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+ 8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+ 9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+ esac
+fi
+
+# Escape application args
+save () {
+ for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+ echo " "
+}
+APP_ARGS=`save "$@"`
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+exec "$JAVACMD" "$@"
diff --git a/counter/gradlew.bat b/counter/gradlew.bat
new file mode 100644
index 0000000..62bd9b9
--- /dev/null
+++ b/counter/gradlew.bat
@@ -0,0 +1,103 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega
diff --git a/counter/settings.gradle b/counter/settings.gradle
new file mode 100644
index 0000000..59f0439
--- /dev/null
+++ b/counter/settings.gradle
@@ -0,0 +1,10 @@
+/*
+ * This file was generated by the Gradle 'init' task.
+ *
+ * The settings file is used to specify which projects to include in your build.
+ *
+ * Detailed information about configuring a multi-project build in Gradle can be found
+ * in the user manual at https://docs.gradle.org/6.3/userguide/multi_project_builds.html
+ */
+
+rootProject.name = 'counter'
diff --git a/counter/src/examples/java/io/synadia/examples/CounterContextExample.java b/counter/src/examples/java/io/synadia/examples/CounterContextExample.java
new file mode 100644
index 0000000..468ecad
--- /dev/null
+++ b/counter/src/examples/java/io/synadia/examples/CounterContextExample.java
@@ -0,0 +1,114 @@
+// Copyright (c) 2025 Synadia Communications Inc. All Rights Reserved.
+// See LICENSE and NOTICE file for details.
+
+package io.synadia.examples;
+
+import io.nats.client.Connection;
+import io.nats.client.JetStreamApiException;
+import io.nats.client.JetStreamManagement;
+import io.nats.client.Nats;
+import io.nats.client.api.StreamConfiguration;
+import io.synadia.counter.CounterContext;
+import io.synadia.counter.CounterEntry;
+
+import java.math.BigInteger;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.TimeUnit;
+
+public class CounterContextExample {
+
+ private static final String STREAM_NAME = "counter-stream";
+ private static final String STREAM_SUBJECT = "cs.*";
+ private static final String SUBJECT_A = "cs.A";
+ private static final String SUBJECT_B = "cs.B";
+ private static final String SUBJECT_C = "cs.C";
+
+ public static void main(String[] args) throws Exception {
+ try (Connection nc = Nats.connect()) {
+ JetStreamManagement jsm = nc.jetStreamManagement();
+
+ // Set up a fresh counter stream
+ try { jsm.deleteStream(STREAM_NAME); } catch (JetStreamApiException ignore) {}
+ CounterContext counter = CounterContext.createCounterStream(nc,
+ StreamConfiguration.builder()
+ .name(STREAM_NAME)
+ .subjects(STREAM_SUBJECT)
+ .build());
+
+ System.out.println("1: Add to a subject...");
+ System.out.println("add(\"" + SUBJECT_A + "\", 1) -> " + counter.add(SUBJECT_A, 1));
+ System.out.println("add(\"" + SUBJECT_A + "\", 2) -> " + counter.add(SUBJECT_A, 2));
+ System.out.println("add(\"" + SUBJECT_A + "\", 3) -> " + counter.add(SUBJECT_A, 3));
+ System.out.println("add(\"" + SUBJECT_A + "\", -1) -> " + counter.add(SUBJECT_A, -1));
+
+ System.out.println("add(\"" + SUBJECT_B + "\", 10) -> " + counter.add(SUBJECT_B, 10));
+ System.out.println("add(\"" + SUBJECT_B + "\", 20) -> " + counter.add(SUBJECT_B, 20));
+ System.out.println("add(\"" + SUBJECT_B + "\", 30) -> " + counter.add(SUBJECT_B, 30));
+ System.out.println("add(\"" + SUBJECT_B + "\", -10) -> " + counter.add(SUBJECT_B, -10));
+
+ System.out.println("add(\"" + SUBJECT_C + "\", 100) -> " + counter.add(SUBJECT_C, 100));
+ System.out.println("add(\"" + SUBJECT_C + "\", 200) -> " + counter.add(SUBJECT_C, 200));
+ System.out.println("add(\"" + SUBJECT_C + "\", 300) -> " + counter.add(SUBJECT_C, 300));
+ System.out.println("add(\"" + SUBJECT_C + "\", -100) -> " + counter.add(SUBJECT_C, -100));
+
+ System.out.println("\n2.1: Get the value for existing subjects");
+ System.out.println("get(\"" + SUBJECT_A + "\") -> " + counter.get(SUBJECT_A));
+ System.out.println("get(\"" + SUBJECT_B + "\") -> " + counter.get(SUBJECT_B));
+ System.out.println("get(\"" + SUBJECT_C + "\") -> " + counter.get(SUBJECT_C));
+
+ System.out.println("\n2.2 Get the value if subject not found");
+ try {
+ counter.get("cs.X");
+ }
+ catch (JetStreamApiException e) {
+ System.out.println("get(\"X\") -> " + e);
+ }
+
+ System.out.println("\n3: Get the full entry for a subject, notice the last increment...");
+ System.out.println("getEntry(\"" + SUBJECT_A + "\") -> " + counter.getEntry(SUBJECT_A));
+ System.out.println("getEntry(\"" + SUBJECT_B + "\") -> " + counter.getEntry(SUBJECT_B));
+ System.out.println("getEntry(\"" + SUBJECT_C + "\") -> " + counter.getEntry(SUBJECT_C));
+
+ System.out.println("\n4: Get multiples entries - maybe to total them up");
+ LinkedBlockingQueue q = counter.getEntries(SUBJECT_A, SUBJECT_B, SUBJECT_C);
+ BigInteger total = BigInteger.ZERO;
+ CounterEntry entry = q.poll(1, TimeUnit.SECONDS);
+ while (entry != null && entry.isEntry()) {
+ System.out.println("Entry: " + entry);
+ total = total.add(entry.value);
+ entry = q.poll(10, TimeUnit.MILLISECONDS);
+ }
+ System.out.println("The last entry was: " + entry);
+ System.out.println("Entries Totaled: " + total);
+
+ System.out.println("\n5.1: Set the value for a subject");
+ System.out.println("set(\"" + SUBJECT_A + "\", 9) -> " + counter.set(SUBJECT_A, 9));
+ System.out.println("set(\"" + SUBJECT_B + "\", 99) -> " + counter.set(SUBJECT_B, 99));
+ System.out.println("set(\"" + SUBJECT_C + "\", 999) -> " + counter.set(SUBJECT_C, 999));
+
+ System.out.println("\n5.2: Get the full entry again, notice the last increment after a set...");
+ System.out.println("getEntry(\"" + SUBJECT_A + "\") -> " + counter.getEntry(SUBJECT_A));
+ System.out.println("getEntry(\"" + SUBJECT_B + "\") -> " + counter.getEntry(SUBJECT_B));
+ System.out.println("getEntry(\"" + SUBJECT_C + "\") -> " + counter.getEntry(SUBJECT_C));
+
+ System.out.println("\n6.1: Zero is a shortcut to set the value for a subject to 0");
+ System.out.println("zero(\"" + SUBJECT_A + "\") -> " + counter.zero(SUBJECT_A));
+ System.out.println("zero(\"" + SUBJECT_B + "\") -> " + counter.zero(SUBJECT_B));
+ System.out.println("zero(\"" + SUBJECT_C + "\") -> " + counter.zero(SUBJECT_C));
+
+ System.out.println("\n6.2: Get the full entry again, notice the last increment after a zero...");
+ System.out.println("getEntry(\"" + SUBJECT_A + "\") -> " + counter.getEntry(SUBJECT_A));
+ System.out.println("getEntry(\"" + SUBJECT_B + "\") -> " + counter.getEntry(SUBJECT_B));
+ System.out.println("getEntry(\"" + SUBJECT_C + "\") -> " + counter.getEntry(SUBJECT_C));
+
+ System.out.println("\n7: Get multiples entries - but subject doesn't have any counters");
+ q = counter.getEntries("not-no counters");
+ entry = q.poll(1, TimeUnit.SECONDS);
+ while (entry != null && entry.isEntry()) {
+ System.out.println("Entry: " + entry);
+ entry = q.poll(10, TimeUnit.MILLISECONDS);
+ }
+ System.out.println("The last entry was: " + entry);
+ }
+ }
+}
diff --git a/counter/src/main/java/io/synadia/counter/CounterContext.java b/counter/src/main/java/io/synadia/counter/CounterContext.java
new file mode 100644
index 0000000..87c9f06
--- /dev/null
+++ b/counter/src/main/java/io/synadia/counter/CounterContext.java
@@ -0,0 +1,136 @@
+// Copyright (c) 2025 Synadia Communications Inc. All Rights Reserved.
+// See LICENSE and NOTICE file for details.
+
+package io.synadia.counter;
+
+import io.nats.client.*;
+import io.nats.client.api.*;
+import io.nats.client.impl.Headers;
+import io.synadia.direct.DirectBatchContext;
+import io.synadia.direct.MessageBatchGetRequest;
+import org.jspecify.annotations.NonNull;
+import org.jspecify.annotations.Nullable;
+
+import java.io.IOException;
+import java.math.BigInteger;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.LinkedBlockingQueue;
+
+import static io.synadia.counter.CounterUtils.INCREMENT_HEADER;
+import static io.synadia.counter.CounterUtils.extractVal;
+
+public class CounterContext {
+
+ public static CounterContext createCounterStream(Connection conn, StreamConfiguration userConfig) throws JetStreamApiException, IOException {
+ return createCounterStream(conn, null, userConfig);
+ }
+
+ public static CounterContext createCounterStream(Connection conn, JetStreamOptions jso, StreamConfiguration userConfig) throws JetStreamApiException, IOException {
+ if (userConfig.getRetentionPolicy() != RetentionPolicy.Limits) {
+ throw new IllegalArgumentException("Retention Policy - Limits is the only allowed limit for counter streams.");
+ }
+ if (userConfig.getDiscardPolicy() == DiscardPolicy.New) {
+ throw new IllegalArgumentException("Discard Policy - New is not allowed for counter streams.");
+ }
+ StreamConfiguration config = StreamConfiguration.builder(userConfig)
+ .allowDirect(true)
+ .allowMessageCounter(true)
+ .build();
+
+ JetStreamManagement jsm = conn.jetStreamManagement(jso);
+ jsm.addStream(config);
+
+ return new CounterContext(config.getName(), conn, jso, jsm);
+ }
+
+ private final String streamName;
+ private final JetStreamManagement jsm;
+ private final JetStream js;
+ private final DirectBatchContext dbCtx;
+
+ public CounterContext(String streamName, Connection conn) throws IOException, JetStreamApiException {
+ this(streamName, conn, null, null);
+ }
+
+ public CounterContext(String streamName, Connection conn, JetStreamOptions jso) throws IOException, JetStreamApiException {
+ this(streamName, conn, jso, null);
+ }
+
+ private CounterContext(@NonNull String streamName, @NonNull Connection conn, @Nullable JetStreamOptions jso, @Nullable JetStreamManagement jsm) throws IOException, JetStreamApiException {
+ this.streamName = streamName;
+ this.jsm = jsm == null ? conn.jetStreamManagement(jso) : jsm;
+ js = this.jsm.jetStream();
+ dbCtx = new DirectBatchContext(conn, jso, streamName);
+ }
+
+ private BigInteger _add(String subject, String sv) throws IOException, JetStreamApiException {
+ Headers h = new Headers();
+ h.put(INCREMENT_HEADER, sv);
+ PublishAck pa = js.publish(subject, h, null);
+ String val = pa.getVal();
+ if (val == null) {
+ throw new IOException("Publish Failed");
+ }
+ return new BigInteger(val);
+ }
+
+ public BigInteger add(String subject, int value) throws JetStreamApiException, IOException {
+ return _add(subject, Integer.toString(value));
+ }
+
+ public BigInteger add(String subject, long value) throws JetStreamApiException, IOException {
+ return _add(subject, Long.toString(value));
+ }
+
+ public BigInteger add(String subject, BigInteger value) throws JetStreamApiException, IOException {
+ return _add(subject, value.toString());
+ }
+
+ public BigInteger increment(String subject) throws JetStreamApiException, IOException {
+ return _add(subject, "1");
+ }
+
+ public BigInteger decrement(String subject) throws JetStreamApiException, IOException {
+ return _add(subject, "-1");
+ }
+
+ public BigInteger set(String subject, int value) throws JetStreamApiException, IOException {
+ return set(subject, BigInteger.valueOf(value));
+ }
+
+ public BigInteger set(String subject, long value) throws JetStreamApiException, IOException {
+ return set(subject, BigInteger.valueOf(value));
+ }
+
+ public BigInteger set(String subject, BigInteger value) throws JetStreamApiException, IOException {
+ // 100 -> 200 = add(200 - 100) | 100 -> 0 = add(0 - 100) | -100 -> 0 = add(0 - -100) | -100 -> 200 = add(200 - -100)
+ BigInteger bi = get(subject);
+ return _add(subject, value.subtract(bi).toString());
+ }
+
+ public BigInteger zero(String subject) throws JetStreamApiException, IOException {
+ return set(subject, BigInteger.ZERO);
+ }
+
+ public BigInteger get(String subject) throws JetStreamApiException, IOException {
+ MessageInfo mi = jsm.getLastMessage(streamName, subject);
+ return new BigInteger(extractVal(mi.getData()));
+ }
+
+ public CounterEntry getEntry(String subject) throws JetStreamApiException, IOException {
+ MessageInfo mi = jsm.getLastMessage(streamName, subject);
+ return new CounterEntry(mi);
+ }
+
+ public LinkedBlockingQueue getEntries(String... subjects) {
+ return getEntries(Arrays.asList(subjects));
+ }
+
+ public LinkedBlockingQueue getEntries(List subjects) {
+ LinkedBlockingQueue queue = new LinkedBlockingQueue<>();
+ MessageBatchGetRequest mbgr = MessageBatchGetRequest.multiLastForSubjects(subjects);
+ dbCtx.requestMessageBatch(mbgr, mi -> queue.add(new CounterEntry(mi)));
+ return queue;
+ }
+}
diff --git a/counter/src/main/java/io/synadia/counter/CounterEntry.java b/counter/src/main/java/io/synadia/counter/CounterEntry.java
new file mode 100644
index 0000000..a547885
--- /dev/null
+++ b/counter/src/main/java/io/synadia/counter/CounterEntry.java
@@ -0,0 +1,112 @@
+// Copyright (c) 2025 Synadia Communications Inc. All Rights Reserved.
+// See LICENSE and NOTICE file for details.
+
+package io.synadia.counter;
+
+import io.nats.client.api.MessageInfo;
+import io.nats.client.support.Status;
+import org.jspecify.annotations.NonNull;
+import org.jspecify.annotations.Nullable;
+
+import java.math.BigInteger;
+import java.util.HashMap;
+import java.util.Map;
+
+import static io.synadia.counter.CounterUtils.extractIncrement;
+import static io.synadia.counter.CounterUtils.extractVal;
+
+public class CounterEntry {
+ public final String subject;
+ public final BigInteger value;
+ public final BigInteger lastIncrement;
+ public final Map sources;
+ public final Status status;
+
+ CounterEntry(MessageInfo mi) {
+ this.status = mi.getStatus();
+ this.sources = new HashMap<>();
+ if (mi.isMessage()) {
+ this.subject = mi.getSubject();
+ this.value = new BigInteger(extractVal(mi.getData()));
+ this.lastIncrement = new BigInteger(extractIncrement(mi.getHeaders()));
+ }
+ else {
+ this.subject = "";
+ this.value = BigInteger.ZERO;
+ this.lastIncrement = BigInteger.ZERO;
+ }
+ }
+
+ /**
+ * Whether this CounterEntry is a regular entry
+ * @return true if the CounterEntry is a regular entry
+ */
+ public boolean isEntry() {
+ return status == null;
+ }
+
+ /**
+ * Whether this CounterEntry is a status message
+ * @return true if this CounterEntry is a status message
+ */
+ public boolean isStatus() {
+ return status != null;
+ }
+
+ /**
+ * Whether this CounterEntry is a status message and is a direct EOB status
+ * @return true if this CounterEntry is a status message and is a direct EOB status
+ */
+ public boolean isEobStatus() {
+ return status != null && status.isEob();
+ }
+
+ /**
+ * Whether this CounterEntry is a status message and is an error status
+ * @return true if this CounterEntry is a status message and is an error status
+ */
+ public boolean isErrorStatus() {
+ return status != null && !status.isEob();
+ }
+
+ @NonNull
+ public String getSubject() {
+ return subject;
+ }
+
+ @NonNull
+ public BigInteger getValue() {
+ return value;
+ }
+
+ @NonNull
+ public BigInteger getLastIncrement() {
+ return lastIncrement;
+ }
+
+ @NonNull
+ public Map getSources() {
+ return sources;
+ }
+
+ @Nullable
+ public Status getStatus() {
+ return status;
+ }
+
+ @Override
+ public String toString() {
+ if (isEntry()) {
+ return "CounterEntry{" +
+ "subject='" + subject + '\'' +
+ ", value=" + value +
+ ", lastIncrement=" + lastIncrement +
+ ", sources=" + sources +
+ '}';
+ }
+
+ return "CounterEntry{" +
+ "status=" + status +
+ '}';
+ }
+}
diff --git a/counter/src/main/java/io/synadia/counter/CounterIterator.java b/counter/src/main/java/io/synadia/counter/CounterIterator.java
new file mode 100644
index 0000000..4889c04
--- /dev/null
+++ b/counter/src/main/java/io/synadia/counter/CounterIterator.java
@@ -0,0 +1,87 @@
+// Copyright (c) 2025 Synadia Communications Inc. All Rights Reserved.
+// See LICENSE and NOTICE file for details.
+
+package io.synadia.counter;
+
+import io.nats.client.api.MessageInfo;
+import io.synadia.direct.MessageInfoHandler;
+
+import java.math.BigInteger;
+import java.util.Iterator;
+import java.util.NoSuchElementException;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+public class CounterIterator implements Iterator, MessageInfoHandler {
+ private final LinkedBlockingQueue queue;
+ private final AtomicBoolean isFinished;
+ private BigInteger nextElement;
+ private boolean hasNextComputed;
+
+ public CounterIterator() {
+ this.queue = new LinkedBlockingQueue<>();
+ this.isFinished = new AtomicBoolean(false);
+ this.nextElement = null;
+ this.hasNextComputed = false;
+ }
+
+ @Override
+ public void onMessageInfo(MessageInfo messageInfo) {
+// if (endMarker.equals(value)) {
+// isFinished.set(true);
+// } else {
+// try {
+// queue.put(value);
+// } catch (InterruptedException e) {
+// Thread.currentThread().interrupt();
+// throw new RuntimeException("Interrupted while adding value", e);
+// }
+// }
+ }
+
+ @Override
+ public boolean hasNext() {
+ if (!hasNextComputed) {
+ computeNext();
+ }
+ return nextElement != null;
+ }
+
+ @Override
+ public BigInteger next() {
+ if (!hasNext()) {
+ throw new NoSuchElementException("No more elements");
+ }
+ BigInteger result = nextElement;
+ hasNextComputed = false;
+ nextElement = null;
+ return result;
+ }
+
+ private void computeNext() {
+ if (hasNextComputed) {
+ return;
+ }
+
+ try {
+ // If we've already seen the end marker, no more elements
+ if (isFinished.get() && queue.isEmpty()) {
+ nextElement = null;
+ } else {
+ // Wait for next element with timeout to avoid infinite blocking
+ nextElement = queue.poll(100, TimeUnit.MILLISECONDS);
+
+ // If queue is empty but not finished, keep polling
+ while (nextElement == null && !isFinished.get()) {
+ nextElement = queue.poll(100, TimeUnit.MILLISECONDS);
+ }
+ }
+ } catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
+ throw new RuntimeException("Interrupted while waiting for next element", e);
+ }
+
+ hasNextComputed = true;
+ }
+}
diff --git a/counter/src/main/java/io/synadia/counter/CounterUtils.java b/counter/src/main/java/io/synadia/counter/CounterUtils.java
new file mode 100644
index 0000000..2584697
--- /dev/null
+++ b/counter/src/main/java/io/synadia/counter/CounterUtils.java
@@ -0,0 +1,25 @@
+// Copyright (c) 2025 Synadia Communications Inc. All Rights Reserved.
+// See LICENSE and NOTICE file for details.
+
+package io.synadia.counter;
+
+import io.nats.client.impl.Headers;
+
+public final class CounterUtils {
+
+ public static final String INCREMENT_HEADER = "Nats-Incr";
+
+ public static String extractVal(byte[] data) {
+ String s = new String(data);
+ // {"val":"-123"}
+ // don't want to assume anything about how the json is formatted/spaced
+ int colonAt = s.indexOf(':');
+ int numberStart = s.indexOf('"', colonAt + 1) + 1;
+ int lastQuote = s.lastIndexOf('"');
+ return s.substring(numberStart, lastQuote).trim();
+ }
+
+ public static String extractIncrement(Headers h) {
+ return h == null ? "0" : h.getFirst(INCREMENT_HEADER);
+ }
+}
diff --git a/counter/src/main/javadoc/images/favicon.ico b/counter/src/main/javadoc/images/favicon.ico
new file mode 100644
index 0000000..9464855
Binary files /dev/null and b/counter/src/main/javadoc/images/favicon.ico differ
diff --git a/counter/src/main/javadoc/images/large-logo.png b/counter/src/main/javadoc/images/large-logo.png
new file mode 100644
index 0000000..33f9483
Binary files /dev/null and b/counter/src/main/javadoc/images/large-logo.png differ
diff --git a/counter/src/main/javadoc/images/synadia-logo.png b/counter/src/main/javadoc/images/synadia-logo.png
new file mode 100644
index 0000000..1f14bda
Binary files /dev/null and b/counter/src/main/javadoc/images/synadia-logo.png differ
diff --git a/counter/src/main/javadoc/overview.html b/counter/src/main/javadoc/overview.html
new file mode 100644
index 0000000..32fb10c
--- /dev/null
+++ b/counter/src/main/javadoc/overview.html
@@ -0,0 +1,13 @@
+
+
+
+
+
+JetStream Distributed Counter
+
+
+
+
+
diff --git a/counter/src/main/resources/placeholder.txt b/counter/src/main/resources/placeholder.txt
new file mode 100644
index 0000000..ca5fd64
--- /dev/null
+++ b/counter/src/main/resources/placeholder.txt
@@ -0,0 +1 @@
+This is just a placeholder.
\ No newline at end of file
diff --git a/counter/src/test/resources/placeholder.txt b/counter/src/test/resources/placeholder.txt
new file mode 100644
index 0000000..ca5fd64
--- /dev/null
+++ b/counter/src/test/resources/placeholder.txt
@@ -0,0 +1 @@
+This is just a placeholder.
\ No newline at end of file
diff --git a/counter/test.bat b/counter/test.bat
new file mode 100644
index 0000000..22c2cd1
--- /dev/null
+++ b/counter/test.bat
@@ -0,0 +1,5 @@
+call gradlew clean build jacocoTestReport
+taskkill /F /IM nats-server.exe
+start chrome file:///C:/nats/orbit.java/counter/build/reports/jacoco/test/html/index.html
+start chrome file:///C:/nats/orbit.java/counter/build/reports/tests/test/index.html
+
diff --git a/direct-batch/build.gradle b/direct-batch/build.gradle
index 6fe666d..470e189 100644
--- a/direct-batch/build.gradle
+++ b/direct-batch/build.gradle
@@ -38,7 +38,7 @@ repositories {
}
dependencies {
- implementation 'io.nats:jnats:2.21.1'
+ implementation 'io.nats:jnats:2.21.5'
testImplementation 'io.nats:jnats-server-runner:1.2.8'
testImplementation 'org.junit.jupiter:junit-jupiter:5.9.0'
diff --git a/direct-batch/src/examples/java/io/synadia/examples/ExampleUtils.java b/direct-batch/src/examples/java/io/synadia/examples/ExampleUtils.java
index 7da03a0..ac53044 100644
--- a/direct-batch/src/examples/java/io/synadia/examples/ExampleUtils.java
+++ b/direct-batch/src/examples/java/io/synadia/examples/ExampleUtils.java
@@ -25,7 +25,8 @@ public static void printMessageInfo(MessageInfo mi, Number listId) {
System.out.println("[" + listId + "] Message"
+ " | subject: " + mi.getSubject()
+ " | sequence: " + mi.getSeq()
- + " | time: " + DateTimeUtils.toRfc3339(mi.getTime()));
+ + " | time: " + (mi.getTime() == null ? "null" : DateTimeUtils.toRfc3339(mi.getTime()))
+ );
}
else {
if (mi.isEobStatus()) {
@@ -34,13 +35,14 @@ public static void printMessageInfo(MessageInfo mi, Number listId) {
else if (mi.isErrorStatus()) {
System.out.print("[" + listId + "] MI Error");
}
- else if (mi.isErrorStatus()) {
+ else if (mi.isStatus()) {
System.out.print("[" + listId + "] MI Status");
}
System.out.println(" | isStatus? " + mi.isStatus()
+ " | isEobStatus? " + mi.isEobStatus()
+ " | isErrorStatus? " + mi.isErrorStatus()
- + " | status code: " + mi.getStatus().getCode());
+ + " | status code: " + (mi.getStatus() == null ? "null" : mi.getStatus().getCode())
+ );
}
}
diff --git a/direct-batch/src/main/java/io/synadia/direct/DirectBatchContext.java b/direct-batch/src/main/java/io/synadia/direct/DirectBatchContext.java
index bc5d0b1..2dbcebc 100644
--- a/direct-batch/src/main/java/io/synadia/direct/DirectBatchContext.java
+++ b/direct-batch/src/main/java/io/synadia/direct/DirectBatchContext.java
@@ -23,7 +23,7 @@ public class DirectBatchContext {
private final Connection conn;
private final JetStreamOptions jso;
private final String streamName;
- final Duration timeout;
+ private final Duration timeout;
/**
* Construct a DirectBatchContext instance.
diff --git a/js-publish-extensions/build.gradle b/js-publish-extensions/build.gradle
index ff76be2..10ce07a 100644
--- a/js-publish-extensions/build.gradle
+++ b/js-publish-extensions/build.gradle
@@ -45,7 +45,7 @@ repositories {
}
dependencies {
- implementation 'io.nats:jnats:2.21.1'
+ implementation 'io.nats:jnats:2.21.5'
implementation 'io.synadia:retrier:0.2.1'
testImplementation 'io.nats:jnats-server-runner:1.2.8'
diff --git a/request-many/build.gradle b/request-many/build.gradle
index 94f7aa6..f862338 100644
--- a/request-many/build.gradle
+++ b/request-many/build.gradle
@@ -38,7 +38,7 @@ repositories {
}
dependencies {
- implementation 'io.nats:jnats:2.21.1'
+ implementation 'io.nats:jnats:2.21.5'
testImplementation 'io.nats:jnats-server-runner:1.2.8'
testImplementation 'org.junit.jupiter:junit-jupiter:5.9.0'
diff --git a/retrier/build.gradle b/retrier/build.gradle
index 5d7e45b..7049817 100644
--- a/retrier/build.gradle
+++ b/retrier/build.gradle
@@ -38,7 +38,7 @@ repositories {
}
dependencies {
- implementation 'io.nats:jnats:2.21.1'
+ implementation 'io.nats:jnats:2.21.5'
testImplementation 'io.nats:jnats-server-runner:1.2.8'
testImplementation 'org.junit.jupiter:junit-jupiter:5.9.0'
