Skip to content

v0.1.2

Latest
Latest

Choose a tag to compare

View all tags
@Midwayne Midwayne released this 16 Jun 19:35
v0.1.2
ca3d4d2
  • Consumer.ConsumeConcurrent for bounded concurrent message handling while
    preserving the same ack, retry and dead-letter semantics as Consume.
  • Consumer.ConsumeBodyConcurrent body-only adapter for concurrent consumers.
    workers <= 1 falls back to the sequential ConsumeBody path.
  • Broker-backed integration coverage for concurrent body consumers, including
    parallel handler execution, effective prefetch raising, retry handling and
    dead-lettering on exhausted concurrent failures.
Assets 2
Loading