diff --git a/src/Spryker/Service/Opentelemetry/Instrumentation/RabbitMqInstrumentation.php b/src/Spryker/Service/Opentelemetry/Instrumentation/RabbitMqInstrumentation.php index 79a66a2..2c5da86 100644 --- 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) {