monitoring

Author: ASKozienko

MonitoringExtension.php

@@ -208,7 +208,7 @@ public function onProcessorException(ProcessorException $context): void
 
     public function onMessageReceived(MessageReceived $context): void
     {
-        $this->received++;
+        ++$this->received;
     }
 
     public function onResult(MessageResult $context): void
@@ -233,7 +233,7 @@ public function onResult(MessageResult $context): void
                 throw new \LogicException();
         }
 
-        $event =  new ConsumedMessageStats(
+        $event = new ConsumedMessageStats(
             $this->consumerId,
             $timeMs,
             $context->getReceivedAt(),
@@ -277,17 +277,14 @@ public function onResult(MessageResult $context): void
 
     public function onPostConsume(PostConsume $context): void
     {
-
     }
 
     public function onPostMessageReceived(PostMessageReceived $context): void
     {
-
     }
 
     public function onInitLogger(InitLogger $context): void
     {
-
     }
 
     private function getNowMs(): int