type fixes

2022-03-22 12:22:29 +02:00
parent 80fa7407d4
commit 1d4030b29e
6 changed files with 36 additions and 2 deletions
@@ -198,12 +198,14 @@ class Queue
            ->limit(0, $batchSize)
            ->find();

-        $webhook = $this->entityManager->getEntity(Webhook::ENTITY_TYPE, $webhookId);
+        $webhook = $this->entityManager->getEntityById(Webhook::ENTITY_TYPE, $webhookId);

        if (!$webhook || !$webhook->get('isActive')) {
            foreach ($itemList as $item) {
                $this->deleteQueueItem($item);
            }
+
+            return;
        }

        $forbiddenAttributeList = [];