| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 | 
							- <?php
 
- /**
 
-  * Copyright © Magento, Inc. All rights reserved.
 
-  * See COPYING.txt for license details.
 
-  */
 
- namespace Magento\Framework\MessageQueue\Config;
 
- use Magento\Framework\Config\ReaderInterface;
 
- use Magento\Framework\Phrase;
 
- /**
 
-  * Composite reader for communication config.
 
-  */
 
- class CompositeReader implements ReaderInterface
 
- {
 
-     /**
 
-      * @var ReaderInterface[]
 
-      */
 
-     private $readers;
 
-     /**
 
-      * Initialize dependencies.
 
-      *
 
-      * @param array $readers
 
-      */
 
-     public function __construct(array $readers)
 
-     {
 
-         $this->readers = [];
 
-         $readers = $this->sortReaders($readers);
 
-         foreach ($readers as $name => $readerInfo) {
 
-             if (!isset($readerInfo['reader']) || !($readerInfo['reader'] instanceof ReaderInterface)) {
 
-                 throw new \InvalidArgumentException(
 
-                     new Phrase(
 
-                         'Reader [%name] must implement Magento\Framework\Config\ReaderInterface',
 
-                         ['name' => $name]
 
-                     )
 
-                 );
 
-             }
 
-             $this->readers[] = $readerInfo['reader'];
 
-         }
 
-     }
 
-     /**
 
-      * Read config.
 
-      *
 
-      * @param string|null $scope
 
-      * @return array
 
-      */
 
-     public function read($scope = null)
 
-     {
 
-         $result = [];
 
-         foreach ($this->readers as $reader) {
 
-             $result = array_replace_recursive($result, $reader->read($scope));
 
-         }
 
-         return $result;
 
-     }
 
-     /**
 
-      * Sort readers according to param 'sortOrder'
 
-      *
 
-      * @param array $readers
 
-      * @return array
 
-      */
 
-     private function sortReaders(array $readers)
 
-     {
 
-         usort(
 
-             $readers,
 
-             function ($firstItem, $secondItem) {
 
-                 $firstValue = 0;
 
-                 $secondValue = 0;
 
-                 if (isset($firstItem['sortOrder'])) {
 
-                     $firstValue = (int)$firstItem['sortOrder'];
 
-                 }
 
-                 if (isset($secondItem['sortOrder'])) {
 
-                     $secondValue = (int)$secondItem['sortOrder'];
 
-                 }
 
-                 return $firstValue <=> $secondValue;
 
-             }
 
-         );
 
-         return $readers;
 
-     }
 
- }
 
 
  |