dashbitco / broadway_rabbitmq

A Broadway producer for RabbitMQ
193 stars 42 forks source link

Add support for consume options #87

Closed whatyouhide closed 3 years ago

whatyouhide commented 3 years ago

We particularly need no_ack: true which is the only way to have guaranteed "at most once" processing with RabbitMQ. Seems fair enough to just set the acknowledger to Broadway.NoopAcknowledger when :no_ack is true.

coveralls commented 3 years ago

Pull Request Test Coverage Report for Build 8c6547cd59f8b74e906f2965e0e8c163bf6873c7-PR-87


Changes Missing Coverage Covered Lines Changed/Added Lines %
lib/broadway_rabbitmq/amqp_client.ex 0 1 0.0%
<!-- Total: 6 7 85.71% -->
Files with Coverage Reduction New Missed Lines %
lib/broadway_rabbitmq/amqp_client.ex 1 30.56%
<!-- Total: 1 -->
Totals Coverage Status
Change from base Build 998d0ea11433b3973e23074888f4db9ffecee33e: 0.4%
Covered Lines: 133
Relevant Lines: 175

💛 - Coveralls