FatalFailures meter fix

avast · Dec 5, 2018 · 22cbaab · 22cbaab
1 parent 5f6c86d
commit 22cbaab
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/com/avast/clients/rabbitmq/DefaultRabbitMQClientFactory.scala b/core/src/main/scala/com/avast/clients/rabbitmq/DefaultRabbitMQClientFactory.scala
@@ -510,6 +510,7 @@ private[rabbitmq] object DefaultRabbitMQClientFactory extends LazyLogging {
 
       } catch {
         case NonFatal(e) =>
+          fatalFailuresMeter.mark()
           logger.error(s"[$name] Error while executing callback, applying DeliveryResult.${consumerConfig.failureAction}", e)
           Effect[F].pure(consumerConfig.failureAction)
       }