Skip to content

Latest commit

 

History

History
24 lines (20 loc) · 1.46 KB

File metadata and controls

24 lines (20 loc) · 1.46 KB

Changelog

All notable changes to com.babelqueue:babelqueue-pulsar are documented here.

The format is based on Keep a Changelog, and this project adheres to Semantic Versioning. The envelope wire format is versioned separately by meta.schema_version (currently 1) — see the contract at babelqueue.com.

[1.0.0] - 2026-06-13

Added

  • Initial release. An Apache Pulsar transport on babelqueue-core + org.apache.pulsar:pulsar-client: PulsarPublisher (canonical-envelope send with the §5 property projection — bq-job = URN, bq-trace-id = trace_id, bq-message-id = meta.id, plus bq-schema-version/bq-source-lang/bq-attempts; native deliverAfter for delays) and PulsarConsumer (receive → URN-routed BabelHandlers → acknowledge; a throwing handler negativeAcknowledges for at-least-once redelivery; attempts reconciled to max(bq-attempts, getRedeliveryCount()) — Pulsar's redelivery count is 0-based so it maps directly with no −1, and the max keeps a republish-driven retry and a native negative-ack redelivery in agreement; onError/onUnknownUrn hooks). Java 17, JUnit 5, JaCoCo ≥90% line coverage; the Producer/Consumer/Message/TypedMessageBuilder interfaces are mocked with Mockito 5 (no Pulsar, no network). The envelope is unchanged (schema_version: 1); Apache Pulsar is purely additive.