|
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