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.
- 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, plusbq-schema-version/bq-source-lang/bq-attempts; nativedeliverAfterfor delays) andPulsarConsumer(receive → URN-routedBabelHandlers →acknowledge; a throwing handlernegativeAcknowledges for at-least-once redelivery;attemptsreconciled tomax(bq-attempts, getRedeliveryCount())— Pulsar's redelivery count is 0-based so it maps directly with no −1, and themaxkeeps a republish-driven retry and a native negative-ack redelivery in agreement;onError/onUnknownUrnhooks). Java 17, JUnit 5, JaCoCo ≥90% line coverage; theProducer/Consumer/Message/TypedMessageBuilderinterfaces are mocked with Mockito 5 (no Pulsar, no network). The envelope is unchanged (schema_version: 1); Apache Pulsar is purely additive.