You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/06/04 08:11:55 UTC
[camel] branch main updated: Regen for commit 2f3f70c20a22ad7c47ac438a11725ee263b53535 (#7722)
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 3aa3eeae389 Regen for commit 2f3f70c20a22ad7c47ac438a11725ee263b53535 (#7722)
3aa3eeae389 is described below
commit 3aa3eeae389560a5ff15e99097d584474f6542d2
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Sat Jun 4 10:11:50 2022 +0200
Regen for commit 2f3f70c20a22ad7c47ac438a11725ee263b53535 (#7722)
Signed-off-by: GitHub <no...@github.com>
Co-authored-by: davsclaus <da...@users.noreply.github.com>
---
.../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 ++++--
6 files changed, 22 insertions(+), 11 deletions(-)
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 888213207d2..9b4adf211e2 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));