From dcc5fc076c5d00599e2118f2175598c8a29751f5 Mon Sep 17 00:00:00 2001
From: Juan Carlos Galvis Zuluaga <jcgalvis@bancolombia.com.co>
Date: Wed, 25 May 2022 11:20:23 -0500
Subject: [PATCH] add metric to async query operation

---
 .../async/rabbit/RabbitDirectAsyncGateway.java              | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/RabbitDirectAsyncGateway.java b/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/RabbitDirectAsyncGateway.java
index 9c42b856..8724c21f 100644
--- a/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/RabbitDirectAsyncGateway.java
+++ b/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/RabbitDirectAsyncGateway.java
@@ -73,7 +73,11 @@ public <T, R> Mono<R> requestReply(AsyncQuery<T> query, String targetName, Class
         headers.put(REPLY_TIMEOUT_MILLIS, replyTimeout.toMillis());
 
         return sender.sendNoConfirm(query, exchange, targetName + ".query", headers, persistentQueries)
-                .then(replyHolder);
+                .then(replyHolder)
+                .name("async_query")
+                .tag("operation", query.getResource())
+                .tag("target", targetName)
+                .metrics();
     }
 
     @Override