Jake Vanderwerf
2026-09-15 01e9a8e40351a87f6548a4f55de842d6f6918ad0
inc/managers/queue/TypeRegistry.php
@@ -3,6 +3,8 @@
if (!defined('ABSPATH')) {
   exit;
}
use InvalidArgumentException;
use JVBase\managers\queue\mergers\DefaultMerger;
final class TypeRegistry
@@ -22,7 +24,7 @@
   public function getExecutor(string $type): ?Executor
   {
      return $this->configs[$type]?->executor;
      return array_key_exists($type, $this->configs) ? $this->configs[$type]->executor : Queue::getInstance()->executor;
   }
   public function getMergeable(string $type): ?Mergeable
@@ -72,7 +74,7 @@
      if ($config->executor && $config->chunkKey) {
         // Verify executor can handle chunked operations
         if (!method_exists($config->executor, 'execute')) {
            throw new \InvalidArgumentException(
            throw new InvalidArgumentException(
               "Executor for '{$type}' must implement execute() method"
            );
         }