add route key header logging

noi-techpark · Oct 25, 2023 · 0509dc7 · 0509dc7
1 parent 317bd32
commit 0509dc7
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/...ctors/lib/ingress-mq/src/main/java/com/opendatahub/collector/lib/ingress/mq/MsgRoute.java b/...ctors/lib/ingress-mq/src/main/java/com/opendatahub/collector/lib/ingress/mq/MsgRoute.java
@@ -32,9 +32,15 @@ public void configure() throws Exception {
                 .routeId("to-odh-ingress-route")
                 .choice()
                 .when(header("route_key").isNull())
-                .process(exchange -> WrapperProcessor.process(exchange, provider))
+                .process(e -> {
+                    log.info("Message to provide {}", provider);
+                    WrapperProcessor.process(e, provider);
+                })
                 .when(header("route_key").isNotNull())
-                .process(exchange -> WrapperProcessor.process(exchange, provider + "_" + header("route_key")))
+                .process(e -> {
+                    log.info("Message with route_key {} to provide {}", header("route_key"), provider);
+                    WrapperProcessor.process(e, provider);
+                })
                 // .to("file:bar?doneFileName=done")
                 .choice()
                 // forward to fastline