From c84f73e9a77256da7e1219eb2398a65f115c3f9f Mon Sep 17 00:00:00 2001
From: Nikita Sarychev <nsarychev@lachestry.com>
Date: Fri, 15 Jan 2021 17:57:05 +0300
Subject: [PATCH] add snake case param name

---
 .../Magento/Framework/MessageQueue/MessageEncoder.php     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/lib/internal/Magento/Framework/MessageQueue/MessageEncoder.php b/lib/internal/Magento/Framework/MessageQueue/MessageEncoder.php
index e8f8e6e3f7118..af4371265089b 100644
--- a/lib/internal/Magento/Framework/MessageQueue/MessageEncoder.php
+++ b/lib/internal/Magento/Framework/MessageQueue/MessageEncoder.php
@@ -176,10 +176,14 @@ protected function convertMessage($topic, $message, $direction, $requestType)
                             ->convertValue($message[$paramPosition], $paramType);
                     }
                 } else {
+                    $snakeCaseParamName = strtolower(preg_replace("/(?<=\\w)(?=[A-Z])/", "_$1", $paramName));
                     /** Encode parameters according to their names in method signature */
-                    if (isset($message[$paramName])) {
+                    if (isset($message[$paramName]) || isset($message[$snakeCaseParamName])) {
+                        $paramValue = isset($message[$paramName])
+                            ? $message[$paramName]
+                            : $message[$snakeCaseParamName];
                         $convertedMessage[$paramName] = $this->getConverter($direction)
-                            ->convertValue($message[$paramName], $paramType);
+                            ->convertValue($paramValue, $paramType);
                     }
                 }