Merge remote-tracking branch 'remotes/github/MAGETWO-96342' into EPAM-PR-34

Author: VeronikaYarats

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

@@ -12,6 +12,11 @@
  */
 class MessageProcessor implements MessageProcessorInterface
 {
+    /**
+     * Maximum number of transaction retries
+     */
+    const MAX_TRANSACTION_RETRIES = 10;
+
     /**
      * @var \Magento\Framework\MessageQueue\MessageStatusProcessor
      */
@@ -22,6 +27,11 @@ class MessageProcessor implements MessageProcessorInterface
      */
     private $resource;
 
+    /**
+     * @var int
+     */
+    private $retryCount = 0;
+
     /**
      * @param MessageStatusProcessor $messageStatusProcessor
      * @param ResourceConnection $resource
@@ -53,8 +63,19 @@ public function process(
         } catch (ConnectionLostException $e) {
             $this->resource->getConnection()->rollBack();
         } catch (\Exception $e) {
+            $retry = false;
             $this->resource->getConnection()->rollBack();
-            $this->messageStatusProcessor->rejectMessages($queue, $messages);
+            if (strpos($e->getMessage(), 'Error while sending QUERY packet') !== false
+                && $this->retryCount < self::MAX_TRANSACTION_RETRIES
+            ) {
+                $retry = true;
+                $this->retryCount++;
+                $this->resource->closeConnection();
+                $this->process($queue, $configuration, $messages, $messagesToAcknowledge, $mergedMessages);
+            }
+            if (!$retry) {
+                $this->messageStatusProcessor->rejectMessages($queue, $messages);
+            }
         }
     }