safe-global / safe-events-service / 24398344334

push

github

fix: await processEvent before acking RabbitMQ message to restore backpressure

Unawaited func() caused channel.ack() to fire synchronously before any
HTTP requests were made, making AMQP_PREFETCH_MESSAGES completely
ineffective and creating unbounded concurrent connections under load.

217 of 252 branches covered (86.11%)

Branch coverage included in aggregate %.

4 of 5 new or added lines in 1 file covered. (80.0%)

581 of 659 relevant lines covered (88.16%)

16.72 hits per line