[camel] branch main updated: CAMEL-19817: camel-timer - Remove firedTime header and turn off metadata headers by default to make the exchange empty, and avoid leaking unwanted headers by default. Add backwards compatible option on component to turn this on globally.

[davsclaus]

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 31738321a25 CAMEL-19817: camel-timer - Remove firedTime header and 
turn off metadata headers by default to make the exchange empty, and avoid 
leaking unwanted headers by default. Add backwards compatible option on 
component to turn this on globally.
31738321a25 is described below

commit 31738321a257b40c1afda5bbaa3277a7bd1d342c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Sep 1 09:26:47 2023 +0200

    CAMEL-19817: camel-timer - Remove firedTime header and turn off metadata 
headers by default to make the exchange empty, and avoid leaking unwanted 
headers by default. Add backwards compatible option on component to turn this 
on globally.
---
 .../component/reactive/streams/BackpressureStrategyTest.java      | 8 ++++----
 .../camel/component/reactive/streams/BasicPublisherTest.java      | 4 ++--
 .../camel/component/reactive/streams/ReactiveStreamsJMXTest.java  | 2 +-
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressureStrategyTest.java
 
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressureStrategyTest.java
index 400656958ec..46c52aa2326 100644
--- 
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressureStrategyTest.java
+++ 
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BackpressureStrategyTest.java
@@ -38,7 +38,7 @@ public class BackpressureStrategyTest extends 
BaseReactiveTest {
         new RouteBuilder() {
             @Override
             public void configure() {
-                from("timer:gen?period=20&repeatCount=20")
+                from("timer:gen?period=20&repeatCount=20&includeMetadata=true")
                         .setBody().header(Exchange.TIMER_COUNTER)
                         .to("reactive-streams:integers");
             }
@@ -76,7 +76,7 @@ public class BackpressureStrategyTest extends 
BaseReactiveTest {
         new RouteBuilder() {
             @Override
             public void configure() {
-                from("timer:gen?period=20&repeatCount=20")
+                from("timer:gen?period=20&repeatCount=20&includeMetadata=true")
                         .setBody().header(Exchange.TIMER_COUNTER)
                         .to("reactive-streams:integers");
             }
@@ -121,7 +121,7 @@ public class BackpressureStrategyTest extends 
BaseReactiveTest {
         new RouteBuilder() {
             @Override
             public void configure() {
-                from("timer:gen?period=20&repeatCount=20")
+                from("timer:gen?period=20&repeatCount=20&includeMetadata=true")
                         .setBody().header(Exchange.TIMER_COUNTER)
                         .to("reactive-streams:integers");
             }
@@ -162,7 +162,7 @@ public class BackpressureStrategyTest extends 
BaseReactiveTest {
         new RouteBuilder() {
             @Override
             public void configure() {
-                from("timer:gen?period=20&repeatCount=20")
+                from("timer:gen?period=20&repeatCount=20&includeMetadata=true")
                         .setBody().header(Exchange.TIMER_COUNTER)
                         
.to("reactive-streams:integers?backpressureStrategy=OLDEST");
             }
diff --git 
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicPublisherTest.java
 
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicPublisherTest.java
index f258342ace9..594d8792d65 100644
--- 
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicPublisherTest.java
+++ 
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicPublisherTest.java
@@ -41,7 +41,7 @@ public class BasicPublisherTest extends BaseReactiveTest {
         new RouteBuilder() {
             @Override
             public void configure() {
-                from("timer:tick?period=5&repeatCount=30")
+                from("timer:tick?period=5&repeatCount=30&includeMetadata=true")
                         .setBody().header(Exchange.TIMER_COUNTER)
                         .to("reactive-streams:pub");
             }
@@ -71,7 +71,7 @@ public class BasicPublisherTest extends BaseReactiveTest {
         new RouteBuilder() {
             @Override
             public void configure() {
-                from("timer:tick?period=50")
+                from("timer:tick?period=50&includeMetadata=true")
                         .setBody().header(Exchange.TIMER_COUNTER)
                         .to("reactive-streams:unbounded");
             }
diff --git 
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
 
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
index 41b827897eb..0e7d9ec58e3 100644
--- 
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
+++ 
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
@@ -120,7 +120,7 @@ public class ReactiveStreamsJMXTest extends 
BaseReactiveTest {
                         .delayer(1)
                         .to("mock:unbounded-endpoint");
 
-                from("timer:tick")
+                from("timer:tick?includeMetadata=true")
                         .setBody().simple("Hello world 
${header.CamelTimerCounter}")
                         .to("reactive-streams:strings");