[camel] branch main updated: (chores) camel-dataset: avoid checking data set index when creating the exchanges

[orpiske]

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

orpiske 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 cbd9302e84f (chores) camel-dataset: avoid checking data set index when 
creating the exchanges
cbd9302e84f is described below

commit cbd9302e84fb6d5e9018acea404c4602d8ecbdaa
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Nov 18 10:52:42 2022 +0100

    (chores) camel-dataset: avoid checking data set index when creating the 
exchanges
---
 .../main/java/org/apache/camel/component/dataset/DataSetConsumer.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
 
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
index 863f5398380..a7e2c80f93c 100644
--- 
a/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
+++ 
b/components/camel-dataset/src/main/java/org/apache/camel/component/dataset/DataSetConsumer.java
@@ -35,11 +35,13 @@ public class DataSetConsumer extends DefaultConsumer {
     private DataSetEndpoint endpoint;
     private Processor reporter;
     private ExecutorService executorService;
+    private final boolean withIndexHeader;
 
     public DataSetConsumer(DataSetEndpoint endpoint, Processor processor) {
         super(endpoint, processor);
         this.endpoint = endpoint;
         this.camelContext = endpoint.getCamelContext();
+        this.withIndexHeader = !endpoint.getDataSetIndex().equals("off");
     }
 
     @Override
@@ -90,7 +92,7 @@ public class DataSetConsumer extends DefaultConsumer {
 
         endpoint.getDataSet().populateMessage(exchange, messageIndex);
 
-        if (!endpoint.getDataSetIndex().equals("off")) {
+        if (withIndexHeader) {
             Message in = exchange.getIn();
             in.setHeader(DataSetConstants.DATASET_INDEX, messageIndex);
         }