Tags: makasim/amqpextra
Toggle v1.2.1's commit message
Cancel consumer before closing channel (#70 )
* Cancel consumer before closing channel
* consumer cancel: fix tests
* consumer cancel: fix linter
Toggle v1.2.0's commit message
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
Toggle v1.1.0's commit message
use publish with context (#68 )
* use publish with context
* remove dbg
Toggle v1.0.0's commit message
Toggle v0.17.0's commit message
Toggle v0.16.4's commit message
Added WithRetryPeriodFunc option (#63 )
* Added WithRetryPeriodFunc option
* Satisfy linter
* Switched to simple implementation
* atomic operations
* Revert "atomic operations"
This reverts commit b94219c .
* Remove defer
Toggle v0.16.3's commit message
Toggle v0.16.2's commit message
Toggle v0.16.1's commit message
Consume from exchange e2e (#47 )
* add e2e test for consume from exchange logic
Toggle v0.16.0's commit message
Consumer from exchange (#45 )
consume from exchange
return queue on ready
You can’t perform that action at this time.