ACP2E-2244: Asynchronous Indexing Errors

Author: dhorytskyi

lib/internal/Magento/Framework/MessageQueue/MessageValidator.php

@@ -119,10 +119,14 @@ protected function validatePrimitiveType($message, $messageType, $topic)
         $realType = $this->getRealType($message);
         if ($realType == 'array' && count($message) == 0) {
             return;
-        } elseif ($realType == 'array' && isset($message[0])) {
-            $realType = $this->getRealType($message[0]);
+        } elseif ($realType == 'array') {
             $compareType = preg_replace('/\[\]/', '', $messageType);
+            foreach ($message as $subMessage) {
+                $this->validatePrimitiveType($subMessage, $compareType, $topic);
+            }
+            return;
         }
+
         if ($realType !== $compareType) {
             throw new InvalidArgumentException(
                 new Phrase(