ResetServicesExtension to run _after_ message received

Resolves #1156

Reset the services after message is received, so that logs are flushed without having to wait for a new message

Author: David Marland

pkg/enqueue-bundle/Consumption/Extension/ResetServicesExtension.php

@@ -2,11 +2,11 @@
 
 namespace Enqueue\Bundle\Consumption\Extension;
 
-use Enqueue\Consumption\Context\MessageReceived;
-use Enqueue\Consumption\MessageReceivedExtensionInterface;
+use Enqueue\Consumption\Context\PostMessageReceived;
+use Enqueue\Consumption\PostMessageReceivedExtensionInterface;
 use Symfony\Component\HttpKernel\DependencyInjection\ServicesResetter;
 
-class ResetServicesExtension implements MessageReceivedExtensionInterface
+class ResetServicesExtension implements PostMessageReceivedExtensionInterface
 {
     /**
      * @var ServicesResetter
@@ -18,7 +18,7 @@ public function __construct(ServicesResetter $resetter)
         $this->resetter = $resetter;
     }
 
-    public function onMessageReceived(MessageReceived $context): void
+    public function onPostMessageReceived(PostMessageReceived $context): void
     {
         $context->getLogger()->debug('[ResetServicesExtension] Resetting services.');
 

pkg/enqueue-bundle/Tests/Unit/Consumption/Extension/ResetServicesExtensionTest.php

@@ -37,7 +37,7 @@ public function testItShouldResetServices()
         ;
 
         $extension = new ResetServicesExtension($resetter);
-        $extension->onMessageReceived($context);
+        $extension->onPostMessageReceived($context);
     }
 
     protected function createContext(): MessageReceived