This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.14.x by this push:
new 8e6bb472842 Regen
8e6bb472842 is described below
commit 8e6bb4728428dc9fe19af01a5a0bff5e4b7f294f
Author: Claus Ibsen <[email protected]>
AuthorDate: Tue Jun 21 13:18:04 2022 +0200
Regen
---
.../resources/org/apache/camel/catalog/components/dropbox.json | 4 ++++
.../org/apache/camel/component/jms/JmsToDSendDynamicTest.java | 1 +
.../camel/component/paho/mqtt5/PahoMqtt5SendDynamicAwareTest.java | 8 +++++---
.../org/apache/camel/component/paho/PahoToDSendDynamicTest.java | 1 +
.../camel/component/rabbitmq/RabbitMQSendDynamicAwareTest.java | 6 ++++--
.../org/apache/camel/component/sjms/SjmsSendDynamicAwareTest.java | 6 ++++--
.../springrabbit/SpringRabbitMQSendDynamicAwareTest.java | 6 ++++--
.../component/vertx/kafka/VertxKafkaSendDynamicAwareTest.java | 6 ++++--
8 files changed, 27 insertions(+), 11 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dropbox.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dropbox.json
index 5e1959f51e4..b8ee470adbd 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dropbox.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dropbox.json
@@ -29,11 +29,15 @@
"properties": {
"operation": { "kind": "path", "displayName": "Operation", "group":
"common", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.dropbox.util.DropboxOperation", "enum": [ "put",
"del", "search", "get", "move" ], "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "The specific action (
[...]
"accessToken": { "kind": "parameter", "displayName": "Access Token",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "The access token to make
API requests for a specific Dropbox user" },
+ "apiKey": { "kind": "parameter", "displayName": "Api Key", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "The apiKey to make API
requests for a specific Dropbox user" },
+ "apiSecret": { "kind": "parameter", "displayName": "Api Secret", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "The apiSecret to make
API requests for a specific Dropbox user" },
"client": { "kind": "parameter", "displayName": "Client", "group":
"common", "label": "", "required": false, "type": "object", "javaType":
"com.dropbox.core.v2.DbxClientV2", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "To use an existing
DbxClient instance as DropBox client." },
"clientIdentifier": { "kind": "parameter", "displayName": "Client
Identifier", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "Name of the app
registered to make API requests" },
+ "expireIn": { "kind": "parameter", "displayName": "Expire In", "group":
"common", "label": "", "required": true, "type": "integer", "javaType":
"java.lang.Long", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "The expire time to
access token for a specific Dropbox user" },
"localPath": { "kind": "parameter", "displayName": "Local Path", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "Optional folder or file
to upload on Dropbox from the local filesystem. If this option has not been
configured then the message [...]
"newRemotePath": { "kind": "parameter", "displayName": "New Remote Path",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "Destination file or
folder" },
"query": { "kind": "parameter", "displayName": "Query", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "A space-separated list
of sub-strings to search for. A file matches only if it contains all the
sub-strings. If this option is not set, a [...]
+ "refreshToken": { "kind": "parameter", "displayName": "Refresh Token",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "The refresh token to
refresh the access token for a specific Dropbox user" },
"remotePath": { "kind": "parameter", "displayName": "Remote Path",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "Original file or folder
to move" },
"uploadMode": { "kind": "parameter", "displayName": "Upload Mode",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.dropbox.util.DropboxUploadMode",
"enum": [ "add", "force" ], "deprecated": false, "autowired": false, "secret":
false, "configurationClass":
"org.apache.camel.component.dropbox.DropboxConfiguration",
"configurationField": "configuration", "description": "Which mode to upload. in
case of add the new file will be [...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
diff --git
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
index 4778953932d..56356d30141 100644
---
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
+++
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsToDSendDynamicTest.java
@@ -43,6 +43,7 @@ public class JmsToDSendDynamicTest extends CamelTestSupport {
out = consumer.receiveBody("activemq:queue:beer", 2000, String.class);
assertEquals("Hello beer", out);
}
+
@Test
public void testToDSlashed() {
template.sendBodyAndHeader("direct:startSlashed", "Hello bar",
"where", "bar");
diff --git
a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SendDynamicAwareTest.java
b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SendDynamicAwareTest.java
index 63b0806d4fe..07b4791baa8 100644
---
a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SendDynamicAwareTest.java
+++
b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SendDynamicAwareTest.java
@@ -38,7 +38,8 @@ public class PahoMqtt5SendDynamicAwareTest extends
CamelTestSupport {
public void testUriParsing() throws Exception {
this.pahoMqtt5SendDynamicAware.setScheme("paho-mqtt5");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("paho-mqtt5:destination",
"paho-mqtt5:${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new
SendDynamicAware.DynamicAwareEntry("paho-mqtt5:destination",
"paho-mqtt5:${header.test}", null, null);
Processor processor =
this.pahoMqtt5SendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(PahoMqtt5Constants.CAMEL_PAHO_OVERRIDE_TOPIC));
@@ -48,9 +49,10 @@ public class PahoMqtt5SendDynamicAwareTest extends
CamelTestSupport {
public void testSlashedUriParsing() throws Exception {
this.pahoMqtt5SendDynamicAware.setScheme("paho-mqtt5");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("paho-mqtt5://destination",
"paho-mqtt5://${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new
SendDynamicAware.DynamicAwareEntry("paho-mqtt5://destination",
"paho-mqtt5://${header.test}", null, null);
Processor processor =
this.pahoMqtt5SendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(PahoMqtt5Constants.CAMEL_PAHO_OVERRIDE_TOPIC));
}
-}
\ No newline at end of file
+}
diff --git
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDSendDynamicTest.java
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDSendDynamicTest.java
index 41cbba0ac9e..8ccf9b2d42f 100644
---
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDSendDynamicTest.java
+++
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDSendDynamicTest.java
@@ -57,6 +57,7 @@ public class PahoToDSendDynamicTest extends CamelTestSupport {
out = consumer.receiveBody("paho:beer", 2000, String.class);
assertEquals("Hello beer", out);
}
+
@Test
public void testToDSlashed() {
template.sendBodyAndHeader("direct:startSlashed", "Hello bar",
"where", "bar");
diff --git
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQSendDynamicAwareTest.java
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQSendDynamicAwareTest.java
index 670d268e849..f3ae0660bd2 100644
---
a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQSendDynamicAwareTest.java
+++
b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQSendDynamicAwareTest.java
@@ -39,7 +39,8 @@ public class RabbitMQSendDynamicAwareTest extends
CamelTestSupport {
public void testUriParsing() throws Exception {
this.rabbitMQSendDynamicAware.setScheme("rabbitmq");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("rabbitmq:destination",
"rabbitmq:${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new
SendDynamicAware.DynamicAwareEntry("rabbitmq:destination",
"rabbitmq:${header.test}", null, null);
Processor processor =
this.rabbitMQSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(RabbitMQConstants.EXCHANGE_OVERRIDE_NAME));
@@ -49,7 +50,8 @@ public class RabbitMQSendDynamicAwareTest extends
CamelTestSupport {
public void testSlashedUriParsing() throws Exception {
this.rabbitMQSendDynamicAware.setScheme("rabbitmq");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("rabbitmq://destination",
"rabbitmq://${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new
SendDynamicAware.DynamicAwareEntry("rabbitmq://destination",
"rabbitmq://${header.test}", null, null);
Processor processor =
this.rabbitMQSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(RabbitMQConstants.EXCHANGE_OVERRIDE_NAME));
diff --git
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsSendDynamicAwareTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsSendDynamicAwareTest.java
index a68489c8924..401c2a68ebe 100644
---
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsSendDynamicAwareTest.java
+++
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsSendDynamicAwareTest.java
@@ -39,7 +39,8 @@ public class SjmsSendDynamicAwareTest extends
CamelTestSupport {
public void testUriParsing() throws Exception {
this.sjmsSendDynamicAware.setScheme("sjms");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("sjms:destination", "sjms:${header.test}",
null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new SendDynamicAware.DynamicAwareEntry("sjms:destination",
"sjms:${header.test}", null, null);
Processor processor =
this.sjmsSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(SjmsConstants.JMS_DESTINATION_NAME));
@@ -49,7 +50,8 @@ public class SjmsSendDynamicAwareTest extends
CamelTestSupport {
public void testSlashedUriParsing() throws Exception {
this.sjmsSendDynamicAware.setScheme("sjms");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("sjms://destination",
"sjms://${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new SendDynamicAware.DynamicAwareEntry("sjms://destination",
"sjms://${header.test}", null, null);
Processor processor =
this.sjmsSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(SjmsConstants.JMS_DESTINATION_NAME));
diff --git
a/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/SpringRabbitMQSendDynamicAwareTest.java
b/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/SpringRabbitMQSendDynamicAwareTest.java
index 1957ae60c78..7f8e0059612 100644
---
a/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/SpringRabbitMQSendDynamicAwareTest.java
+++
b/components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/SpringRabbitMQSendDynamicAwareTest.java
@@ -39,7 +39,8 @@ public class SpringRabbitMQSendDynamicAwareTest extends
CamelTestSupport {
public void testUriParsing() throws Exception {
this.springRabbitMQSendDynamicAware.setScheme("spring-rabbitmq");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("spring-rabbitmq:destination",
"spring-rabbitmq:${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry(
+ "spring-rabbitmq:destination",
"spring-rabbitmq:${header.test}", null, null);
Processor processor =
this.springRabbitMQSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(SpringRabbitMQConstants.EXCHANGE_OVERRIDE_NAME));
@@ -49,7 +50,8 @@ public class SpringRabbitMQSendDynamicAwareTest extends
CamelTestSupport {
public void testSlashedUriParsing() throws Exception {
this.springRabbitMQSendDynamicAware.setScheme("spring-rabbitmq");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("spring-rabbitmq://destination",
"spring-rabbitmq://${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry(
+ "spring-rabbitmq://destination",
"spring-rabbitmq://${header.test}", null, null);
Processor processor =
this.springRabbitMQSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(SpringRabbitMQConstants.EXCHANGE_OVERRIDE_NAME));
diff --git
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaSendDynamicAwareTest.java
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaSendDynamicAwareTest.java
index fe8c6f417f8..11ea5812b3e 100644
---
a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaSendDynamicAwareTest.java
+++
b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaSendDynamicAwareTest.java
@@ -39,7 +39,8 @@ public class VertxKafkaSendDynamicAwareTest extends
CamelTestSupport {
public void testUriParsing() throws Exception {
this.vertxKafkaSendDynamicAware.setScheme("vertx-kafka");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("vertx-kafka:destination",
"vertx-kafka:${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry
+ = new
SendDynamicAware.DynamicAwareEntry("vertx-kafka:destination",
"vertx-kafka:${header.test}", null, null);
Processor processor =
this.vertxKafkaSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(VertxKafkaConstants.OVERRIDE_TOPIC));
@@ -49,7 +50,8 @@ public class VertxKafkaSendDynamicAwareTest extends
CamelTestSupport {
public void testSlashedUriParsing() throws Exception {
this.vertxKafkaSendDynamicAware.setScheme("vertx-kafka");
Exchange exchange = createExchangeWithBody("The Body");
- SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry("vertx-kafka://destination",
"vertx-kafka://${header.test}", null, null);
+ SendDynamicAware.DynamicAwareEntry entry = new
SendDynamicAware.DynamicAwareEntry(
+ "vertx-kafka://destination", "vertx-kafka://${header.test}",
null, null);
Processor processor =
this.vertxKafkaSendDynamicAware.createPreProcessor(createExchangeWithBody("Body"),
entry);
processor.process(exchange);
assertEquals("destination",
exchange.getMessage().getHeader(VertxKafkaConstants.OVERRIDE_TOPIC));
