v0.8.1 - publish backoff & retry on delivery tag mismatch

What's Changed

• introduce backoff policy for publisher by @jxsl13 in #62

Full Changelog: v0.8.0...v0.8.1

v0.8.0 - the context update

What's Changed

Monitoring:

• introduce callbacks for every retryable operation and for session and connections by @jxsl13 in #48
• add multiple StatXXX pool methods for fetching the current pool state

Dependencies:

• Bump codecov/codecov-action from 3 to 4 by @dependabot in #47

Bugfix:

• fix incorrect context passed by @jxsl13 in #49
• implement correct connection flow control handling for publishers (fixes #50)

Breaking Changes:

• the context update by @jxsl13 in #51
  • Size() methods are now called Capacity() and Size() refers to the currently idle connection/sessions in a pool
  • Publish timeout and AwaitConfirms timeout were removed in favor of a single context for both (pool.Publisher)
  • all methods now require a context to be passed. (fixes #44)
  • HandlerFuncs, BatchHandlerFuncs, TopologyFuncs receive an additional context parameter which is canceled upon pool context cancelation

Feature:

• add a special error for rejecting messages pool.ErrReject (pool.ErrRejectSingle) (fixes #46)
• removes internal queue and replaces it with a Go channel (removes dependency) (fixes #4)

CI/CD:

• all tests can now be run in parallel
• limit parallelization of tests in GitHub Action to 2 tests being run in parallel due to weird GitHub runner behavior.

Full Changelog: v0.7.2...v0.8.0

v0.7.2

What's Changed

• feature: Read Write Mutex by @escb005 in #40
• Bump github/codeql-action from 2 to 3 by @dependabot in #39
• Bump actions/setup-go from 4 to 5 by @dependabot in #38
• feature: batch bytes by @john-behm-bertelsmann in #41
• initial test for internal state context object by @john-behm-bertelsmann in #42

New Contributors

• @escb005 made their first contribution in #40

Full Changelog: v0.7.1...v0.7.2

v0.7.1 - edge case mitigation

• prevent the consumer reconnect from consuming 100% cpu in case that the queue they conume from was deleted while the consumer was paused.

v0.7.0 - pause/resume message processing

• add the feature to pause/resume processing of messages

v0.6.6 - improve recoverability check

• improve recoverability check

v0.6.5 - logging cleanup

• hide empty consumer tag log field
• show batch flush interval in string representation and not integer (nanos)
• fix staticcheck warning in tests

v0.6.4 - update dependencies

Update dependencies

• Bump github.com/Workiva/go-datastructures from 1.0.53 to 1.1.0
• Bump go.uber.org/goleak from 1.2.0 to 1.2.1
• Bump github.com/rabbitmq/amqp091-go from 1.7.0 to 1.8.1

v0.6.3 - persistent delivery mode by default

• make message deliveries persistent by default
• makes every message persisted to disk by default in order to recover events upon rabbitmq node restart

v0.6.2 - autoAck drops messages that failed processing

• improve subscriber consumption routines
• explicitly log that batches/messages were dropped