(camel) branch main updated: CAMEL-18858: camel-kamelet - Create a copy of exchange when kamelet is acting as source, so the exchange is faked to be created directly by the consumer itself, so it originate from the user route, and make the kamelet as it was just like any other regular Camel component.

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 8f5bd79c2c4 CAMEL-18858: camel-kamelet - Create a copy of exchange when kamelet is acting as source, so the exchange is faked to be created directly by the consumer itself, so it originate from the user route, and make the kamelet as it was just like any other regular Camel component.
8f5bd79c2c4 is described below

commit 8f5bd79c2c44a68e9e996f9cedd05baf86c657ba
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Mar 2 09:57:07 2024 +0100

    CAMEL-18858: camel-kamelet - Create a copy of exchange when kamelet is acting as source, so the exchange is faked to be created directly by the consumer itself, so it originate from the user route, and make the kamelet as it was just like any other regular Camel component.
---
 .../routepolicy/MicrometerRoutePolicyMulticastSubRouteTest.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/MicrometerRoutePolicyMulticastSubRouteTest.java b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/MicrometerRoutePolicyMulticastSubRouteTest.java
index de2a50b803f..bb39dd94b3f 100644
--- a/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/MicrometerRoutePolicyMulticastSubRouteTest.java
+++ b/components/camel-micrometer/src/test/java/org/apache/camel/component/micrometer/routepolicy/MicrometerRoutePolicyMulticastSubRouteTest.java
@@ -107,7 +107,7 @@ public class MicrometerRoutePolicyMulticastSubRouteTest extends AbstractMicromet
                     Counter counter = (Counter) meter;
                     int expectedCount;
                     String routeId = counter.getId().getTag("routeId");
-                    if (routeId.equals("failureHandled")) {
+                    if (routeId.equals("failureHandled") || routeId.equals("multicast")) {
                         expectedCount = count;
                     } else {
                         expectedCount = 0;