|
8 | 8 |
|
9 | 9 | namespace Magento\AsynchronousOperations\Model; |
10 | 10 |
|
11 | | -use Magento\Framework\Serialize\Serializer\Json; |
12 | 11 | use Magento\AsynchronousOperations\Api\Data\OperationInterface; |
13 | | -use Magento\Framework\Bulk\OperationManagementInterface; |
14 | 12 | use Magento\AsynchronousOperations\Model\ConfigInterface as AsyncConfig; |
15 | | -use Magento\Framework\MessageQueue\MessageValidator; |
16 | | -use Magento\Framework\MessageQueue\MessageEncoder; |
17 | | -use Magento\Framework\Exception\NoSuchEntityException; |
18 | | -use Magento\Framework\MessageQueue\ConsumerConfigurationInterface; |
19 | | -use Psr\Log\LoggerInterface; |
20 | | -use Magento\Framework\Exception\LocalizedException; |
| 13 | +use Magento\Framework\Bulk\OperationManagementInterface; |
| 14 | +use Magento\Framework\Communication\ConfigInterface as CommunicationConfig; |
21 | 15 | use Magento\Framework\DB\Adapter\ConnectionException; |
22 | 16 | use Magento\Framework\DB\Adapter\DeadlockException; |
23 | 17 | use Magento\Framework\DB\Adapter\LockWaitException; |
| 18 | +use Magento\Framework\Exception\LocalizedException; |
| 19 | +use Magento\Framework\Exception\NoSuchEntityException; |
| 20 | +use Magento\Framework\MessageQueue\ConsumerConfigurationInterface; |
| 21 | +use Magento\Framework\MessageQueue\MessageEncoder; |
| 22 | +use Magento\Framework\MessageQueue\MessageValidator; |
| 23 | +use Magento\Framework\Serialize\Serializer\Json; |
24 | 24 | use Magento\Framework\Webapi\ServiceOutputProcessor; |
25 | | -use Magento\Framework\Communication\ConfigInterface as CommunicationConfig; |
| 25 | +use Psr\Log\LoggerInterface; |
26 | 26 |
|
27 | 27 | /** |
28 | | - * Class OperationProcessor |
| 28 | + * Proccess operation |
29 | 29 | * |
30 | 30 | * @SuppressWarnings(PHPMD.CouplingBetweenObjects) |
31 | 31 | */ |
@@ -136,7 +136,9 @@ public function process(string $encodedMessage) |
136 | 136 | $result = $this->executeHandler($callback, $entityParams); |
137 | 137 | $status = $result['status']; |
138 | 138 | $errorCode = $result['error_code']; |
| 139 | + // phpcs:disable Magento2.Performance.ForeachArrayMerge |
139 | 140 | $messages = array_merge($messages, $result['messages']); |
| 141 | + // phpcs:enable Magento2.Performance.ForeachArrayMerge |
140 | 142 | $outputData = $result['output_data']; |
141 | 143 | } |
142 | 144 | } |
@@ -186,7 +188,9 @@ private function executeHandler($callback, $entityParams) |
186 | 188 | 'output_data' => null |
187 | 189 | ]; |
188 | 190 | try { |
| 191 | + // phpcs:disable Magento2.Functions.DiscouragedFunction |
189 | 192 | $result['output_data'] = call_user_func_array($callback, $entityParams); |
| 193 | + // phpcs:enable Magento2.Functions.DiscouragedFunction |
190 | 194 | $result['messages'][] = sprintf('Service execution success %s::%s', get_class($callback[0]), $callback[1]); |
191 | 195 | } catch (\Zend_Db_Adapter_Exception $e) { |
192 | 196 | $this->logger->critical($e->getMessage()); |
|
0 commit comments