From 1cec9eff0427f6e300da2073505f10c15dccc280 Mon Sep 17 00:00:00 2001 From: Eloi Charpentier Date: Thu, 21 Nov 2024 14:43:52 +0100 Subject: [PATCH] core: log execution time when processing messages Signed-off-by: Eloi Charpentier --- core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt b/core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt index e52a96c5718..52222378fab 100644 --- a/core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt +++ b/core/src/main/java/fr/sncf/osrd/cli/WorkerCommand.kt @@ -175,6 +175,7 @@ class WorkerCommand : CliCommand { val channel = connection.createChannel() val callback = fun(message: Delivery) { + val startTimeMS = System.currentTimeMillis() reportActivity(activityChannel, "request-received") val replyTo = message.properties.replyTo @@ -281,7 +282,12 @@ class WorkerCommand : CliCommand { } channel.basicAck(message.envelope.deliveryTag, false) - logger.info("request for path {} processed", path) + val executionTimeMS = System.currentTimeMillis() - startTimeMS + logger.info( + "request for path {} processed in {}s", + path, + executionTimeMS / 1_000.0 + ) } channel.basicConsume( WORKER_REQUESTS_QUEUE,