Skip to content

Commit cbca76d

Browse files
authored
Merge pull request #69 from reactive-commons/feature/query-metric
add metric to async query operation
2 parents 6708d4e + dcc5fc0 commit cbca76d

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/RabbitDirectAsyncGateway.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,11 @@ public <T, R> Mono<R> requestReply(AsyncQuery<T> query, String targetName, Class
7373
headers.put(REPLY_TIMEOUT_MILLIS, replyTimeout.toMillis());
7474

7575
return sender.sendNoConfirm(query, exchange, targetName + ".query", headers, persistentQueries)
76-
.then(replyHolder);
76+
.then(replyHolder)
77+
.name("async_query")
78+
.tag("operation", query.getResource())
79+
.tag("target", targetName)
80+
.metrics();
7781
}
7882

7983
@Override

0 commit comments

Comments
 (0)