diff --git a/pkg/enqueue-bundle/Consumption/Extension/ResetServicesExtension.php b/pkg/enqueue-bundle/Consumption/Extension/ResetServicesExtension.php index 36eb21782..0bf642197 100644 --- a/pkg/enqueue-bundle/Consumption/Extension/ResetServicesExtension.php +++ b/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.'); diff --git a/pkg/enqueue-bundle/Tests/Unit/Consumption/Extension/ResetServicesExtensionTest.php b/pkg/enqueue-bundle/Tests/Unit/Consumption/Extension/ResetServicesExtensionTest.php index bfd772a5c..18e94f251 100644 --- a/pkg/enqueue-bundle/Tests/Unit/Consumption/Extension/ResetServicesExtensionTest.php +++ b/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),