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 <omars...@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:
*
<code>org.apache.camel.component.stitch.client.StitchRegion</code>
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:
*
<code>org.apache.camel.component.stitch.client.StitchRegion</code>
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
*
<code>org.apache.camel.component.stitch.client.StitchRegion</code>
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()
