Merge pull request #1172 from djmarland/post-message

ResetServicesExtension to run _after_ message received

Author: makasim

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

@@ -4,7 +4,7 @@
 
 use Doctrine\Persistence\ManagerRegistry;
 use Enqueue\Bundle\Consumption\Extension\ResetServicesExtension;
-use Enqueue\Consumption\Context\MessageReceived;
+use Enqueue\Consumption\Context\PostMessageReceived;
 use Interop\Queue\Consumer;
 use Interop\Queue\Context as InteropContext;
 use Interop\Queue\Message;
@@ -37,12 +37,12 @@ public function testItShouldResetServices()
         ;
 
         $extension = new ResetServicesExtension($resetter);
-        $extension->onMessageReceived($context);
+        $extension->onPostMessageReceived($context);
     }
 
-    protected function createContext(): MessageReceived
+    protected function createContext(): PostMessageReceived
     {
-        return new MessageReceived(
+        return new PostMessageReceived(
             $this->createMock(InteropContext::class),
             $this->createMock(Consumer::class),
             $this->createMock(Message::class),