Adding requestId filter

oracle · Apr 12, 2022 · bb77481 · bb77481
1 parent 8de90e5
commit bb77481
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/Oracle/M2/Advanced/ExtensionAbstract.php b/Oracle/M2/Advanced/ExtensionAbstract.php
@@ -133,7 +133,7 @@ public function processEvents($observer)
             $this->_queueManager->deleteByIds($script['data']['eventIds']);
         }
         $results = [self::PROCESS_KEY_SUCCESS => 0, self::PROCESS_KEY_ERROR => 0];
-        $disabled = $this->_connectorSettings->isFlushDisabled($registration->getScope(), $registration->getScopeId()) && $script['data']['requestId'];
+        $disabled = $this->_connectorSettings->isFlushDisabled($registration->getScope(), $registration->getScopeId()) && array_key_exists('requestId', $script['data']) && $script['data']['requestId'];
         if (!$disabled) {
             $batchSize = $this->_connectorSettings->getBatchSize($registration->getScope(), $registration->getScopeId());
             $errorHandlerSet = false;