FRW-9742 Adjusted Rabbit MQ instrumentation

spryker · Jan 15, 2025 · 9653f43 · 9653f43
1 parent 9b40127
commit 9653f43
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/src/Spryker/Service/Opentelemetry/Instrumentation/RabbitMqInstrumentation.php b/src/Spryker/Service/Opentelemetry/Instrumentation/RabbitMqInstrumentation.php
@@ -65,6 +65,26 @@ class RabbitMqInstrumentation
      */
     protected const FUNCTION_SEND_MESSAGE = 'sendMessage';
 
+    /**
+     * @var string
+     */
+    protected const FUNCTION_RECEIVE_MESSAGE = 'receiveMessage';
+
+    /**
+     * @var string
+     */
+    protected const FUNCTION_RECEIVE_MESSAGES = 'receiveMessages';
+
+    /**
+     * @var string
+     */
+    protected const SPAN_NAME_RECEIVE_MESSAGE = 'rabbitmq-receiveMessage';
+
+    /**
+     * @var string
+     */
+    protected const SPAN_NAME_RECEIVE_MESSAGES = 'rabbitmq-receiveMessages';
+
     /**
      * @return void
      */
@@ -73,6 +93,8 @@ public static function register(): void
         $functions = [
             static::FUNCTION_SEND_MESSAGE => static::SPAN_NAME_SEND_MESSAGE,
             static::FUNCTION_SEND_MESSAGES => static::SPAN_NAME_SEND_MESSAGES,
+            static::FUNCTION_RECEIVE_MESSAGE => static::SPAN_NAME_RECEIVE_MESSAGE,
+            static::FUNCTION_RECEIVE_MESSAGES => static::SPAN_NAME_RECEIVE_MESSAGES,
         ];
 
         foreach ($functions as $function => $spanName) {