You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by oa...@apache.org on 2021/01/27 11:40:51 UTC

[camel] branch master updated: Fix StitchReigon default value

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 63e1bb6  Fix StitchReigon default value
63e1bb6 is described below

commit 63e1bb656ae56b5d9ddede7202ca32ef4ec46de6
Author: Omar Al-Safi <om...@gmail.com>
AuthorDate: Wed Jan 27 12:40:15 2021 +0100

    Fix StitchReigon default value
---
 .../org/apache/camel/catalog/docs/stitch-component.adoc        | 10 +++++-----
 .../resources/org/apache/camel/component/stitch/stitch.json    |  4 ++--
 components/camel-stitch/src/main/docs/stitch-component.adoc    |  4 ++--
 .../org/apache/camel/component/stitch/StitchConfiguration.java |  2 +-
 .../builder/component/dsl/StitchComponentBuilderFactory.java   |  2 +-
 .../builder/endpoint/dsl/StitchEndpointBuilderFactory.java     |  4 ++--
 docs/components/modules/ROOT/pages/stitch-component.adoc       | 10 +++++-----
 7 files changed, 18 insertions(+), 18 deletions(-)

diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stitch-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stitch-component.adoc
index 7bfac91..1edb3e0 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stitch-component.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stitch-component.adoc
@@ -94,7 +94,7 @@ with the following path and query parameters:
 | Name | Description | Default | Type
 | *keyNames* (producer) | A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary Keys to de-dupe data during loading If not provided, the table will be loaded in an append-only manner. |  | String
 | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | europe | StitchRegion
+| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | EUROPE | StitchRegion
 | *stitchSchema* (producer) | *Autowired* A schema that describes the record(s) |  | StitchSchema
 | *connectionProvider* (producer) | *Autowired* ConnectionProvider contain configuration for the HttpClient like Maximum connection limit .. etc, you can inject this ConnectionProvider and the StitchClient will initialize HttpClient with this ConnectionProvider |  | ConnectionProvider
 | *httpClient* (producer) | *Autowired* Reactor Netty HttpClient, you can injected it if you want to have custom HttpClient |  | HttpClient
@@ -115,7 +115,7 @@ The Stitch component supports 10 options, which are listed below.
 | *configuration* (producer) | The component configurations |  | StitchConfiguration
 | *keyNames* (producer) | A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary Keys to de-dupe data during loading If not provided, the table will be loaded in an append-only manner. |  | String
 | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | europe | StitchRegion
+| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | EUROPE | StitchRegion
 | *stitchSchema* (producer) | *Autowired* A schema that describes the record(s) |  | StitchSchema
 | *connectionProvider* (producer) | *Autowired* ConnectionProvider contain configuration for the HttpClient like Maximum connection limit .. etc, you can inject this ConnectionProvider and the StitchClient will initialize HttpClient with this ConnectionProvider |  | ConnectionProvider
 | *httpClient* (producer) | *Autowired* Reactor Netty HttpClient, you can injected it if you want to have custom HttpClient |  | HttpClient
@@ -208,7 +208,7 @@ from("direct:sendStitch")
 from("direct:sendStitch")
      .process(exchange -> {
          exchange.getMessage().setHeader(StitchConstants.SCHEMA, StitchSchema.builder().addKeyword("field_1", "string").build());
-         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, Collections.singleton("field_1"));
+         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, "field_1");
          exchange.getMessage().setHeader(StitchConstants.TABLE_NAME, "table_1");
 
          final StitchMessage stitchMessage = StitchMessage.builder()
@@ -237,7 +237,7 @@ from("direct:sendStitch")
         data.put(StitchRequestBody.SCHEMA, Collections.singletonMap("properties", properties));
         data.put(StitchRequestBody.MESSAGES,
                 Collections.singletonList(Collections.singletonMap("data", Collections.singletonMap("id", 2))));
-        data.put(StitchRequestBody.KEY_NAMES, Collections.singletonList("test_key"));
+        data.put(StitchRequestBody.KEY_NAMES, "test_key");
 
         exchange.getMessage().setBody(data);
      })
@@ -252,7 +252,7 @@ from("direct:sendStitch")
 from("direct:sendStitch")
      .process(exchange -> {
          exchange.getMessage().setHeader(StitchConstants.SCHEMA, StitchSchema.builder().addKeyword("field_1", "string").build());
-         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, Collections.singleton("field_1"));
+         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, "field_1");
          exchange.getMessage().setHeader(StitchConstants.TABLE_NAME, "table_1");
 
         final StitchMessage stitchMessage1 = StitchMessage.builder()
diff --git a/components/camel-stitch/src/generated/resources/org/apache/camel/component/stitch/stitch.json b/components/camel-stitch/src/generated/resources/org/apache/camel/component/stitch/stitch.json
index 04a327f..d9d6808 100644
--- a/components/camel-stitch/src/generated/resources/org/apache/camel/component/stitch/stitch.json
+++ b/components/camel-stitch/src/generated/resources/org/apache/camel/component/stitch/stitch.json
@@ -25,7 +25,7 @@
     "configuration": { "kind": "property", "displayName": "Configuration", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.StitchConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "The component configurations" },
     "keyNames": { "kind": "property", "displayName": "Key Names", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary K [...]
     "lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during star [...]
-    "region": { "kind": "property", "displayName": "Region", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.client.StitchRegion", "enum": [ "NORTH_AMERICA", "EUROPE" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "europe", "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "Stitch account region, e.g [...]
+    "region": { "kind": "property", "displayName": "Region", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.client.StitchRegion", "enum": [ "NORTH_AMERICA", "EUROPE" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "EUROPE", "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "Stitch account region, e.g [...]
     "stitchSchema": { "kind": "property", "displayName": "Stitch Schema", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.client.models.StitchSchema", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "A schema that describes the record(s)" },
     "connectionProvider": { "kind": "property", "displayName": "Connection Provider", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "object", "javaType": "reactor.netty.resources.ConnectionProvider", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "ConnectionProvider contain configur [...]
     "httpClient": { "kind": "property", "displayName": "Http Client", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "object", "javaType": "reactor.netty.http.client.HttpClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "Reactor Netty HttpClient, you can injected it if you want [...]
@@ -37,7 +37,7 @@
     "tableName": { "kind": "path", "displayName": "Table Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "The name of the destination table the data is being pushed to. Table names must be unique in each destination schema, or loading issu [...]
     "keyNames": { "kind": "parameter", "displayName": "Key Names", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary  [...]
     "lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during sta [...]
-    "region": { "kind": "parameter", "displayName": "Region", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.client.StitchRegion", "enum": [ "NORTH_AMERICA", "EUROPE" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "europe", "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "Stitch account region, e. [...]
+    "region": { "kind": "parameter", "displayName": "Region", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.client.StitchRegion", "enum": [ "NORTH_AMERICA", "EUROPE" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "EUROPE", "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "Stitch account region, e. [...]
     "stitchSchema": { "kind": "parameter", "displayName": "Stitch Schema", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.stitch.client.models.StitchSchema", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "A schema that describes the record(s)" },
     "connectionProvider": { "kind": "parameter", "displayName": "Connection Provider", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "object", "javaType": "reactor.netty.resources.ConnectionProvider", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "ConnectionProvider contain configu [...]
     "httpClient": { "kind": "parameter", "displayName": "Http Client", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "object", "javaType": "reactor.netty.http.client.HttpClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.stitch.StitchConfiguration", "configurationField": "configuration", "description": "Reactor Netty HttpClient, you can injected it if you wan [...]
diff --git a/components/camel-stitch/src/main/docs/stitch-component.adoc b/components/camel-stitch/src/main/docs/stitch-component.adoc
index de02a1b..1edb3e0 100644
--- a/components/camel-stitch/src/main/docs/stitch-component.adoc
+++ b/components/camel-stitch/src/main/docs/stitch-component.adoc
@@ -94,7 +94,7 @@ with the following path and query parameters:
 | Name | Description | Default | Type
 | *keyNames* (producer) | A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary Keys to de-dupe data during loading If not provided, the table will be loaded in an append-only manner. |  | String
 | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | europe | StitchRegion
+| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | EUROPE | StitchRegion
 | *stitchSchema* (producer) | *Autowired* A schema that describes the record(s) |  | StitchSchema
 | *connectionProvider* (producer) | *Autowired* ConnectionProvider contain configuration for the HttpClient like Maximum connection limit .. etc, you can inject this ConnectionProvider and the StitchClient will initialize HttpClient with this ConnectionProvider |  | ConnectionProvider
 | *httpClient* (producer) | *Autowired* Reactor Netty HttpClient, you can injected it if you want to have custom HttpClient |  | HttpClient
@@ -115,7 +115,7 @@ The Stitch component supports 10 options, which are listed below.
 | *configuration* (producer) | The component configurations |  | StitchConfiguration
 | *keyNames* (producer) | A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary Keys to de-dupe data during loading If not provided, the table will be loaded in an append-only manner. |  | String
 | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | europe | StitchRegion
+| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | EUROPE | StitchRegion
 | *stitchSchema* (producer) | *Autowired* A schema that describes the record(s) |  | StitchSchema
 | *connectionProvider* (producer) | *Autowired* ConnectionProvider contain configuration for the HttpClient like Maximum connection limit .. etc, you can inject this ConnectionProvider and the StitchClient will initialize HttpClient with this ConnectionProvider |  | ConnectionProvider
 | *httpClient* (producer) | *Autowired* Reactor Netty HttpClient, you can injected it if you want to have custom HttpClient |  | HttpClient
diff --git a/components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchConfiguration.java b/components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchConfiguration.java
index 802a07c..1e4b078 100644
--- a/components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchConfiguration.java
+++ b/components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchConfiguration.java
@@ -35,7 +35,7 @@ public class StitchConfiguration implements Cloneable {
     @UriParam(label = "security", secret = true)
     @Metadata(required = true)
     private String token;
-    @UriParam(label = "producer", defaultValue = "europe")
+    @UriParam(label = "producer", defaultValue = "EUROPE")
     private StitchRegion region = StitchRegion.EUROPE;
     @UriParam(label = "producer")
     @Metadata(autowired = true)
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StitchComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StitchComponentBuilderFactory.java
index 8853dff..bfbb9ce 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StitchComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StitchComponentBuilderFactory.java
@@ -115,7 +115,7 @@ public interface StitchComponentBuilderFactory {
          * The option is a:
          * &lt;code&gt;org.apache.camel.component.stitch.client.StitchRegion&lt;/code&gt; type.
          * 
-         * Default: europe
+         * Default: EUROPE
          * Group: producer
          * 
          * @param region the value to set
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StitchEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StitchEndpointBuilderFactory.java
index 1a9069b..4cd57fd 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StitchEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StitchEndpointBuilderFactory.java
@@ -109,7 +109,7 @@ public interface StitchEndpointBuilderFactory {
          * The option is a:
          * &lt;code&gt;org.apache.camel.component.stitch.client.StitchRegion&lt;/code&gt; type.
          * 
-         * Default: europe
+         * Default: EUROPE
          * Group: producer
          * 
          * @param region the value to set
@@ -125,7 +125,7 @@ public interface StitchEndpointBuilderFactory {
          * The option will be converted to a
          * &lt;code&gt;org.apache.camel.component.stitch.client.StitchRegion&lt;/code&gt; type.
          * 
-         * Default: europe
+         * Default: EUROPE
          * Group: producer
          * 
          * @param region the value to set
diff --git a/docs/components/modules/ROOT/pages/stitch-component.adoc b/docs/components/modules/ROOT/pages/stitch-component.adoc
index 9f0c5bc..b7dda6c 100644
--- a/docs/components/modules/ROOT/pages/stitch-component.adoc
+++ b/docs/components/modules/ROOT/pages/stitch-component.adoc
@@ -96,7 +96,7 @@ with the following path and query parameters:
 | Name | Description | Default | Type
 | *keyNames* (producer) | A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary Keys to de-dupe data during loading If not provided, the table will be loaded in an append-only manner. |  | String
 | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | europe | StitchRegion
+| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | EUROPE | StitchRegion
 | *stitchSchema* (producer) | *Autowired* A schema that describes the record(s) |  | StitchSchema
 | *connectionProvider* (producer) | *Autowired* ConnectionProvider contain configuration for the HttpClient like Maximum connection limit .. etc, you can inject this ConnectionProvider and the StitchClient will initialize HttpClient with this ConnectionProvider |  | ConnectionProvider
 | *httpClient* (producer) | *Autowired* Reactor Netty HttpClient, you can injected it if you want to have custom HttpClient |  | HttpClient
@@ -117,7 +117,7 @@ The Stitch component supports 10 options, which are listed below.
 | *configuration* (producer) | The component configurations |  | StitchConfiguration
 | *keyNames* (producer) | A collection of comma separated strings representing the Primary Key fields in the source table. Stitch use these Primary Keys to de-dupe data during loading If not provided, the table will be loaded in an append-only manner. |  | String
 | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
-| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | europe | StitchRegion
+| *region* (producer) | Stitch account region, e.g: europe. There are 2 enums and the value can be one of: NORTH_AMERICA, EUROPE | EUROPE | StitchRegion
 | *stitchSchema* (producer) | *Autowired* A schema that describes the record(s) |  | StitchSchema
 | *connectionProvider* (producer) | *Autowired* ConnectionProvider contain configuration for the HttpClient like Maximum connection limit .. etc, you can inject this ConnectionProvider and the StitchClient will initialize HttpClient with this ConnectionProvider |  | ConnectionProvider
 | *httpClient* (producer) | *Autowired* Reactor Netty HttpClient, you can injected it if you want to have custom HttpClient |  | HttpClient
@@ -210,7 +210,7 @@ from("direct:sendStitch")
 from("direct:sendStitch")
      .process(exchange -> {
          exchange.getMessage().setHeader(StitchConstants.SCHEMA, StitchSchema.builder().addKeyword("field_1", "string").build());
-         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, Collections.singleton("field_1"));
+         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, "field_1");
          exchange.getMessage().setHeader(StitchConstants.TABLE_NAME, "table_1");
 
          final StitchMessage stitchMessage = StitchMessage.builder()
@@ -239,7 +239,7 @@ from("direct:sendStitch")
         data.put(StitchRequestBody.SCHEMA, Collections.singletonMap("properties", properties));
         data.put(StitchRequestBody.MESSAGES,
                 Collections.singletonList(Collections.singletonMap("data", Collections.singletonMap("id", 2))));
-        data.put(StitchRequestBody.KEY_NAMES, Collections.singletonList("test_key"));
+        data.put(StitchRequestBody.KEY_NAMES, "test_key");
 
         exchange.getMessage().setBody(data);
      })
@@ -254,7 +254,7 @@ from("direct:sendStitch")
 from("direct:sendStitch")
      .process(exchange -> {
          exchange.getMessage().setHeader(StitchConstants.SCHEMA, StitchSchema.builder().addKeyword("field_1", "string").build());
-         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, Collections.singleton("field_1"));
+         exchange.getMessage().setHeader(StitchConstants.KEY_NAMES, "field_1");
          exchange.getMessage().setHeader(StitchConstants.TABLE_NAME, "table_1");
 
         final StitchMessage stitchMessage1 = StitchMessage.builder()