Skip to content

Tags: makasim/amqpextra

Tags

v1.2.1

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Cancel consumer before closing channel (#70)

* Cancel consumer before closing channel

* consumer cancel: fix tests

* consumer cancel: fix linter

v1.2.0

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Consumer pool. In-process consumer autoscaling. (#69)

* consumer pool

* upd

* fix linter issues, add initCtx

* configure initCtx, decouple from consumer and logger

* default decider adjustments

* default decider

* default decider

* default decider

* add e2e-test

* fix linter

* several consumers per connection

* fix linter

* bigger init time

* add note to readme

v1.1.0

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
use publish with context (#68)

* use publish with context

* remove dbg

v1.0.0

fix dependabot issue

v0.17.0

Verified

This tag was signed with the committer’s verified signature.
makasim Max Kotliar
Release v0.17.0

v0.16.4

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Added WithRetryPeriodFunc option (#63)

* Added WithRetryPeriodFunc option

* Satisfy linter

* Switched to simple implementation

* atomic operations

* Revert "atomic operations"

This reverts commit b94219c.

* Remove defer

v0.16.3

simply examples

v0.16.2

simplify dialer example

v0.16.1

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Consume from exchange e2e (#47)

* add e2e test for consume from exchange logic

v0.16.0

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Consumer from exchange (#45)

consume from exchange
return queue on ready