diff --git a/src/Services/UpgradeManager.php b/src/Services/UpgradeManager.php
index 7fb2d7c..c3da772 100644
--- a/src/Services/UpgradeManager.php
+++ b/src/Services/UpgradeManager.php
@@ -68,6 +68,7 @@ public function run(RunConfiguration $configuration, OutputInterface $output): v
 
         $this->processHelper->console(['scheduled-task:register']);
         $this->processHelper->console(['messenger:setup-transports']);
+        $this->processHelper->console(['messenger:stop-workers']);
 
         $this->pluginHelper->installPlugins($configuration->skipAssetsInstall);
         $this->pluginHelper->updatePlugins($configuration->skipAssetsInstall);
diff --git a/tests/Services/UpgradeManagerTest.php b/tests/Services/UpgradeManagerTest.php
index b49f042..d650b2f 100644
--- a/tests/Services/UpgradeManagerTest.php
+++ b/tests/Services/UpgradeManagerTest.php
@@ -124,7 +124,7 @@ public function testRunUpdatesVersionNoAssetCompile(): void
 
         $manager->run(new RunConfiguration(true, true), $this->createMock(OutputInterface::class));
 
-        static::assertCount(4, $consoleCommands);
+        static::assertCount(5, $consoleCommands);
         static::assertSame(['system:update:finish', '--skip-asset-build'], $consoleCommands[0]);
     }
 
@@ -165,7 +165,7 @@ public function testRunWithDifferentSalesChannelUrl(): void
 
         $manager->run(new RunConfiguration(), $this->createMock(OutputInterface::class));
 
-        static::assertCount(6, $consoleCommands);
+        static::assertCount(7, $consoleCommands);
         static::assertSame(['sales-channel:create:storefront', '--name=Storefront', '--url=http://foo.com'], $consoleCommands[0]);
     }
 
@@ -206,10 +206,10 @@ public function testRunWithMaintenanceMode(): void
 
         $manager->run(new RunConfiguration(), $this->createMock(OutputInterface::class));
 
-        static::assertCount(6, $consoleCommands);
+        static::assertCount(7, $consoleCommands);
         static::assertSame(['cache:pool:clear', 'cache.http', 'cache.object'], $consoleCommands[0]);
-        static::assertArrayHasKey(5, $consoleCommands);
-        static::assertSame(['cache:pool:clear', 'cache.http', 'cache.object'], $consoleCommands[5]);
+        static::assertArrayHasKey(6, $consoleCommands);
+        static::assertSame(['cache:pool:clear', 'cache.http', 'cache.object'], $consoleCommands[6]);
     }
 
     public function testRunWithLicenseDomain(): void