riverqueue/river java/v0.1.0-alpha.1

on GitHub

Added

• First alpha release of River for Java. com.riverqueue:river provides a Java 21 client and worker runtime for Postgres and SQLite, sharing River's database schema and job protocol with other River clients. Includes typed jobs, virtual-thread workers, transactional inserts, unique, scheduled, periodic, and resumable jobs, queue management, hooks, middleware, events, and migrations.
• Standalone migration CLI, published as com.riverqueue:river-cli with classifier all. The executable JAR bundles both JDBC drivers and supports applying, reverting, listing, and exporting migrations.

Changed

• Breaking: Replaced Extension and Client.withExtension with operation-specific hook and middleware interfaces, matching River for Go: HookInsertBegin, HookPeriodicJobsStart, HookWorkBegin, HookWorkEnd, JobInsertMiddleware, and WorkerMiddleware. Register them with Client.withPlugins to activate all interfaces an instance implements, or with withHooks and withMiddleware to activate only that side. Plugins run before separately registered hooks and middleware. Each operation-specific interface supports lambdas and checked exceptions. The afterClaim callback was removed; use worker middleware for work before the handler. PR #1519.
• HookWorkEnd.workEnd returns the attempt's failure: return the incoming failure to preserve it, a replacement to change it, or null to report success. Each hook receives the previous hook's result, so hooks migrated from Extension.afterWork must explicitly return the failure to preserve the outcome. A work-begin failure now skips both the handler and work-end hooks. PR #1519.
• Insertion middleware now receives the batch's submissions and returns its insertion results. It runs once per batch, including a one-element batch for single inserts, while insertion hooks run once per job. Hooks and middleware run inside the insertion's transaction. PR #1519.
• Renamed the internal River Pro storage interface and its registration method from Plugin/Client.withPlugin to Pilot/Client.withPilot. Plugin is now the common marker interface for application hooks and middleware. PR #1519.

Fixed

• Fail retries that omit a saved cursor-only step, while preserving their checkpoints for recovery. Jobs with an existing step marker retain their behavior, including legacy stale cursor entries. PR #1534.

• Replace whole top-level metadata values on SQLite, including JSON null, matching Postgres. Completed resumable cursor steps no longer run again because of stale cursor entries. PR #1533.