davsclaus commented on code in PR #27910:
URL: https://github.com/apache/camel/pull/27910#discussion_r4303037104
##########
components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitorItemLifecycleTest.java:
##########
@@ -128,7 +142,14 @@ public void configure() {
from(resolve(MILO_CLIENT_UNKNOWN_ITEM)).routeId("unknownItem").to(MOCK_UNKNOWN_ITEM);
// the consumers deliver the current values while they start,
so the tests start these routes
-
from(resolve(MILO_CLIENT_ITEM_1)).routeId("item1").autoStartup(false).to(MOCK_ITEM_1);
+
from(resolve(MILO_CLIENT_ITEM_1)).routeId("item1").autoStartup(false)
+ .process(exchange -> {
+ final Object value =
exchange.getMessage().getBody(DataValue.class).getValue().getValue();
+ if (SLOW_VALUE.equals(value) &&
slowValueProcessed.compareAndSet(false, true)) {
+ Thread.sleep(3000);
Review Comment:
Done in 581cdf637118: the route of the first item now holds the delivery
thread for the slow value with `.filter(...).delay(3000).syncDelayed().end()`,
the check moved into `isSlowValueOnce(Exchange)`, so the test no longer calls
`Thread.sleep()`. The branch also has main merged in (017e5c7097de) to pick up
the `ServerCertificateValidationTest` fix of CAMEL-25645, with the 4.24 upgrade
guide conflict resolved by keeping both sides.
_Claude Code on behalf of Claus Ibsen_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
