From 5d804a6511f56dc036110758770944f0d8da8182 Mon Sep 17 00:00:00 2001 From: Croway Date: Mon, 4 Mar 2024 16:30:47 +0100 Subject: [PATCH] Migrate timer examples to 4.4 --- .../example/reactive/streams/BasicCamelToReactorExample.java | 4 ++-- .../reactive/streams/BasicCamelToReactorInOutExample.java | 2 +- .../src/main/resources/myroutes/my-yaml-route.yaml | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorExample.java b/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorExample.java index d175257b..f15bc42d 100644 --- a/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorExample.java +++ b/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorExample.java @@ -81,12 +81,12 @@ public static class BasicCamelToReactorExampleRoutes extends RouteBuilder { public void configure() throws Exception { // Generating numbers every 5 seconds and forwarding to the stream "numbers" - from("timer:clock?period=5000") + from("timer:clock?period=5000&includeMetadata=true") .setBody().header(Exchange.TIMER_COUNTER) .to("reactive-streams:numbers"); // Generating strings every 4.9 seconds and forwarding to the stream "strings" - from("timer:clock2?period=4900&delay=2000") + from("timer:clock2?period=4900&delay=2000&includeMetadata=true") .setBody().simple("Hello World ${header.CamelTimerCounter}!") .to("reactive-streams:strings"); diff --git a/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorInOutExample.java b/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorInOutExample.java index 3f612666..cea11187 100644 --- a/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorInOutExample.java +++ b/reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/BasicCamelToReactorInOutExample.java @@ -80,7 +80,7 @@ public static class BasicCamelToReactorInOutExampleRoutes extends RouteBuilder { public void configure() throws Exception { // Generate a Id and retrieve user data from reactor - from("timer:clock?period=9000&delay=1500") + from("timer:clock?period=9000&delay=1500&includeMetadata=true") .setBody().header(Exchange.TIMER_COUNTER).convertBodyTo(Long.class) // Sample ID .bean("userBean", "getUserInfo") // Get the user info from reactor code .process(new UnwrapStreamProcessor()) // Unwrap the Publisher diff --git a/routes-configuration/src/main/resources/myroutes/my-yaml-route.yaml b/routes-configuration/src/main/resources/myroutes/my-yaml-route.yaml index 3639f6d0..73340eb5 100644 --- a/routes-configuration/src/main/resources/myroutes/my-yaml-route.yaml +++ b/routes-configuration/src/main/resources/myroutes/my-yaml-route.yaml @@ -19,7 +19,7 @@ # refer to the route configuration by the id to use for this route routeConfigurationId: "yamlError" from: - uri: "timer:yaml?period=3s" + uri: "timer:yaml?period=3s&includeMetadata=true" steps: - setBody: simple: "Timer fired ${header.CamelTimerCounter} times"