v1.4.9

What's Changed

• DP-92: Expose awaitNoMessagesInFlight convenience method for callers to block until count is 0 by @blakesmith in #88
• DP-92: Release 1.4.9 by @blakesmith in #89

Full Changelog: v1.4.8...v1.4.9

v1.4.8

What's Changed

• DP-85: Add Subscriber#drainInFlight, to support graceful in-flight shutdown. by @blakesmith in #85
• DP-85: Release 1.4.8 by @blakesmith in #86

Full Changelog: v1.4.7...v1.4.8

v1.4.7

What's Changed

• DP-84: Add lookup method to query the total in-flight message count of all subscriptions by @blakesmith in #81
• LIS-9781: Introduce SubscriptionId for unique subscription identifiers by @blakesmith in #82
• LIS-9781: Release version 1.4.7 by @blakesmith in #83

Full Changelog: v1.4.6...v1.4.7

v1.4.6

What's Changed

• Check connection liveness before attempting to publish (dp-58) by @prestonhansen, @kalitanick, @blakesmith in #74
• Release 1.4.6 and add instructions for maintainers. (dp-58) by @prestonhansen, @blakesmith in #75

Full Changelog: v1.4.5...v1.4.6

v1.4.5

What's Changed

• DP-44: Correct skip syntax by @blakesmith in #68
• DP-44: Fixup GH workflow by @blakesmith in #69
• DP-61: Make test teardown operations more null-safe. by @blakesmith in #70
• DP-61: Run nsq-j tests on merge to main by @blakesmith in #71
• DP-61: More minor test flakiness cleanups by @blakesmith in #72
• DP-62: error -> info logging during connection shutdown errors. by @blakesmith in #73

Full Changelog: v1.4.4...v1.4.5

v1.4.4

What's Changed

• BUGFIX DP-44: Don't attempt to read the response from nsqd on CLS command by @blakesmith in #67

Full Changelog: v1.4.3...v1.4.4

1.4.3: Subscriber bugfixes

• Bug fix for correct Subscriber connection closing. #62
• Dependency upgrades.

What's Changed

• DP-44: Bump guava from 31.1-jre to 32.0.0-jre by @dependabot in #55
• DP-44: Bump org.xerial.snappy:snappy-java from 1.1.8.4 to 1.1.10.4 by @dependabot in #63
• DP-44: Bump ch.qos.logback:logback-classic from 1.2.11 to 1.2.13 by @dependabot in #64
• DP-44: Bump ch.qos.logback:logback-core from 1.2.11 to 1.2.13 by @dependabot in #65
• DP-44: Cleanup nsqd subscription connections correctly during unsubscribe. by @blakesmith in #62
• DP-44: Release 1.4.3 by @blakesmith in #66

New Contributors

• @dependabot made their first contribution in #55

Full Changelog: v1.4.2...v1.4.3

Release 1.4.2

Minor Features

• Subscriber: Add the ability to unsubscribe an already active subscription.

v1.4.1: Merge pull request #53 from blakesmith/release_1.4.1

Bug Fixes

• Bugfix: When all nsqd connections get marked as FAILED, attempt to reopen connections for retry. #52
• Bugfix: Restore old sequential publishing behavior during an MPUB failure. #51

Release 1.4

New Features

• The Publisher class can now be configured with a BalanceStrategy implementation. The client will still default to the existing "failover" behavior, with a single nsqd node to publish to, and a backup nsqd node.
• We've exposed a new constructor in the Publisher interface to allow it to take an ordered list of nsqd nodes to publish to, beyond a single nsqd primary and backup.
• We've also added support for "round-robin" style publisher balancing, which will evenly distribute messages across the given list of nsqd nodes. Failed nodes will follow the same retry / timeout behavior. See ListBasedBalanceStrategy#getRoundRobinStrategyBuilder and the updated README for more details.
• Publisher#publishDeferredWithRetry method has been added to support deferred publishing, with retry behavior.

Other Improvements

• The entire test suite has been rewritten, which allows us to simulate node failures and test the client failure behavior.
• Connection failure state has been moved off the Publisher directly, and now lives on the ConnectionDetails object.

Breaking Changes

• The Message interface now has an additional forceFlush method that must be implemented. If you implement the Message interface in your own code, you'll need to add this. If your code relies on NSQMessage, this has already been taken care of.