You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/04 14:18:45 UTC
[camel] branch main updated (00c8cbbba68 -> 7a2dd724e10)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 00c8cbbba68 camel-jbang - Add --deps to export so you eg can add management via --deps=camel:management
new 69229f5b910 (chores) camel-kafka: forces fork reuse in integration tests
new ea3918398c8 (chores) camel-kafka: use separate resources for the idempotent tests
new f8d6cf7afa1 (chores) camel-kafka: reorganized the health tests
new dce306ffd53 (chores) camel-kafka: let junit manage the service lifecycle in health tests
new 7a2dd724e10 (chores) camel-kafka: skip health tests when using Strimzi
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
components/camel-kafka/pom.xml | 5 +++++
.../{ => health}/KafkaConsumerBadPortHealthCheckIT.java | 16 +++++++---------
.../KafkaConsumerBadPortSupervisingHealthCheckIT.java | 16 +++++++---------
.../KafkaConsumerUnresolvableHealthCheckIT.java | 6 +++++-
.../kafka/KafkaIdempotentRepositoryEagerIT.java | 8 +++-----
.../kafka/KafkaIdempotentRepositoryNonEagerIT.java | 6 +++---
.../kafka/KafkaIdempotentRepositoryPersistenceIT.java | 4 ++--
7 files changed, 32 insertions(+), 29 deletions(-)
rename components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/{ => health}/KafkaConsumerBadPortHealthCheckIT.java (93%)
rename components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/{ => health}/KafkaConsumerBadPortSupervisingHealthCheckIT.java (93%)
rename components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/{ => health}/KafkaConsumerUnresolvableHealthCheckIT.java (94%)
[camel] 05/05: (chores) camel-kafka: skip health tests when using Strimzi
Posted by or...@apache.org.
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
commit 7a2dd724e1067c73781e496a7c0b47b50bfa2046
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Aug 4 13:52:05 2022 +0200
(chores) camel-kafka: skip health tests when using Strimzi
The way our test infra launches Strimzi causes a conflict when running multiple containers at the same time
---
.../kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java | 3 +++
.../health/KafkaConsumerBadPortSupervisingHealthCheckIT.java | 3 +++
.../integration/health/KafkaConsumerUnresolvableHealthCheckIT.java | 3 +++
3 files changed, 9 insertions(+)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
index db8ae66848f..a7a6703490e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
@@ -50,6 +50,7 @@ import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -58,6 +59,8 @@ import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
+@DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-strimzi-container",
+ disabledReason = "Test infra Kafka runs the Strimzi containers in a way that conflicts with multiple concurrent images")
public class KafkaConsumerBadPortHealthCheckIT extends CamelTestSupport {
public static final String TOPIC = "test-health";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
index c4e246851ae..6e680b452e9 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
@@ -52,6 +52,7 @@ import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -60,6 +61,8 @@ import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
+@DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-strimzi-container",
+ disabledReason = "Test infra Kafka runs the Strimzi containers in a way that conflicts with multiple concurrent images")
public class KafkaConsumerBadPortSupervisingHealthCheckIT extends CamelTestSupport {
public static final String TOPIC = "test-health";
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
index cd1c94ea43e..1026131e4b2 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
@@ -51,6 +51,7 @@ import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -58,6 +59,8 @@ import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
+@DisabledIfSystemProperty(named = "kafka.instance.type", matches = "local-strimzi-container",
+ disabledReason = "Test infra Kafka runs the Strimzi containers in a way that conflicts with multiple concurrent images")
public class KafkaConsumerUnresolvableHealthCheckIT extends CamelTestSupport {
public static final String TOPIC = "test-health";
[camel] 01/05: (chores) camel-kafka: forces fork reuse in integration tests
Posted by or...@apache.org.
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
commit 69229f5b9103144d287d8a2a7fed5e176a0fc671
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Aug 4 13:31:05 2022 +0200
(chores) camel-kafka: forces fork reuse in integration tests
---
components/camel-kafka/pom.xml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/components/camel-kafka/pom.xml b/components/camel-kafka/pom.xml
index 9fdd78e609b..6f56ef02ec0 100644
--- a/components/camel-kafka/pom.xml
+++ b/components/camel-kafka/pom.xml
@@ -132,6 +132,9 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-failsafe-plugin</artifactId>
+ <configuration>
+ <reuseForks>true</reuseForks>
+ </configuration>
<executions>
<execution>
<id>kafka-3</id>
@@ -139,6 +142,7 @@
<systemPropertyVariables>
<kafka.instance.type>local-kafka3-container</kafka.instance.type>
</systemPropertyVariables>
+ <reuseForks>true</reuseForks>
<reportNameSuffix>kafka-3</reportNameSuffix>
</configuration>
<goals>
@@ -147,6 +151,7 @@
</goals>
</execution>
</executions>
+
</plugin>
</plugins>
</build>
[camel] 04/05: (chores) camel-kafka: let junit manage the service lifecycle in health tests
Posted by or...@apache.org.
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
commit dce306ffd53f85012bb641594cfad598529c1720
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Aug 4 13:50:34 2022 +0200
(chores) camel-kafka: let junit manage the service lifecycle in health tests
---
.../health/KafkaConsumerBadPortHealthCheckIT.java | 13 ++++---------
.../KafkaConsumerBadPortSupervisingHealthCheckIT.java | 13 ++++---------
.../health/KafkaConsumerUnresolvableHealthCheckIT.java | 3 ++-
3 files changed, 10 insertions(+), 19 deletions(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
index ca0e6ffe46c..db8ae66848f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.kafka.integration;
+package org.apache.camel.component.kafka.integration.health;
import java.util.Collection;
import java.util.Collections;
@@ -28,6 +28,7 @@ import org.apache.camel.EndpointInject;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaComponent;
import org.apache.camel.component.kafka.MockConsumerInterceptor;
+import org.apache.camel.component.kafka.integration.BaseEmbeddedKafkaTestSupport;
import org.apache.camel.component.kafka.serde.DefaultKafkaHeaderDeserializer;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.health.HealthCheck;
@@ -40,7 +41,6 @@ import org.apache.camel.test.junit5.CamelTestSupport;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.header.internals.RecordHeader;
-import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
@@ -50,6 +50,7 @@ import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -60,6 +61,7 @@ import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
public class KafkaConsumerBadPortHealthCheckIT extends CamelTestSupport {
public static final String TOPIC = "test-health";
+ @RegisterExtension
public static KafkaService service = KafkaServiceFactory.createService();
protected static AdminClient kafkaAdminClient;
@@ -88,18 +90,11 @@ public class KafkaConsumerBadPortHealthCheckIT extends CamelTestSupport {
@BeforeAll
public static void beforeClass() {
- service.initialize();
-
LOG.info("### Embedded Kafka cluster broker list: {}", service.getBootstrapServers());
System.setProperty("bootstrapServers", service.getBootstrapServers());
System.setProperty("brokers", service.getBootstrapServers());
}
- @AfterAll
- public static void afterClass() {
- service.shutdown();
- }
-
@BeforeEach
public void setKafkaAdminClient() {
if (kafkaAdminClient == null) {
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
index 40c7b37afd5..c4e246851ae 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.kafka.integration;
+package org.apache.camel.component.kafka.integration.health;
import java.util.Collection;
import java.util.Collections;
@@ -28,6 +28,7 @@ import org.apache.camel.EndpointInject;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaComponent;
import org.apache.camel.component.kafka.MockConsumerInterceptor;
+import org.apache.camel.component.kafka.integration.BaseEmbeddedKafkaTestSupport;
import org.apache.camel.component.kafka.serde.DefaultKafkaHeaderDeserializer;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.health.HealthCheck;
@@ -42,7 +43,6 @@ import org.apache.camel.test.junit5.CamelTestSupport;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.header.internals.RecordHeader;
-import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
@@ -52,6 +52,7 @@ import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.extension.RegisterExtension;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -62,6 +63,7 @@ import static org.testcontainers.shaded.org.awaitility.Awaitility.await;
public class KafkaConsumerBadPortSupervisingHealthCheckIT extends CamelTestSupport {
public static final String TOPIC = "test-health";
+ @RegisterExtension
public static KafkaService service = KafkaServiceFactory.createService();
protected static AdminClient kafkaAdminClient;
@@ -90,18 +92,11 @@ public class KafkaConsumerBadPortSupervisingHealthCheckIT extends CamelTestSuppo
@BeforeAll
public static void beforeClass() {
- service.initialize();
-
LOG.info("### Embedded Kafka cluster broker list: {}", service.getBootstrapServers());
System.setProperty("bootstrapServers", service.getBootstrapServers());
System.setProperty("brokers", service.getBootstrapServers());
}
- @AfterAll
- public static void afterClass() {
- service.shutdown();
- }
-
@BeforeEach
public void setKafkaAdminClient() {
if (kafkaAdminClient == null) {
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
index 1eea3220c46..cd1c94ea43e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.kafka.integration;
+package org.apache.camel.component.kafka.integration.health;
import java.util.Collection;
import java.util.Collections;
@@ -28,6 +28,7 @@ import org.apache.camel.EndpointInject;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaComponent;
import org.apache.camel.component.kafka.MockConsumerInterceptor;
+import org.apache.camel.component.kafka.integration.BaseEmbeddedKafkaTestSupport;
import org.apache.camel.component.kafka.serde.DefaultKafkaHeaderDeserializer;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.health.HealthCheck;
[camel] 02/05: (chores) camel-kafka: use separate resources for the idempotent tests
Posted by or...@apache.org.
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
commit ea3918398c80927d4809aecad8d6f109edc7d68d
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Aug 4 13:32:16 2022 +0200
(chores) camel-kafka: use separate resources for the idempotent tests
---
.../idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java | 8 +++-----
.../idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java | 6 +++---
.../idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java | 4 ++--
3 files changed, 8 insertions(+), 10 deletions(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
index 0b8104be695..e95a0f0642e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
@@ -18,7 +18,6 @@ package org.apache.camel.processor.idempotent.kafka;
import java.util.UUID;
-import org.apache.camel.BindToRegistry;
import org.apache.camel.CamelExecutionException;
import org.apache.camel.EndpointInject;
import org.apache.camel.RoutesBuilder;
@@ -36,8 +35,6 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
@TestInstance(TestInstance.Lifecycle.PER_METHOD)
public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSupport {
- // Every instance of the repository must use a different topic to guarantee isolation between tests
- @BindToRegistry("kafkaIdempotentRepository")
private KafkaIdempotentRepository kafkaIdempotentRepository;
@EndpointInject("mock:out")
@@ -48,14 +45,15 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
@Override
protected RoutesBuilder createRouteBuilder() {
+ // Every instance of the repository must use a different topic to guarantee isolation between tests
kafkaIdempotentRepository = new KafkaIdempotentRepository("TEST_EAGER_" + UUID.randomUUID(), getBootstrapServers());
- context.getRegistry().bind("kafkaIdempotentRepository", kafkaIdempotentRepository);
+ context.getRegistry().bind("kafkaIdempotentRepositoryEager", kafkaIdempotentRepository);
return new RouteBuilder() {
@Override
public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
- .idempotentRepository("kafkaIdempotentRepository").to("mock:out").end();
+ .idempotentRepository("kafkaIdempotentRepositoryEager").to("mock:out").end();
}
};
}
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
index cb2314c31be..4df97548cdf 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
@@ -37,7 +37,6 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
@TestInstance(TestInstance.Lifecycle.PER_METHOD)
public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSupport {
- // Every instance of the repository must use a different topic to guarantee isolation between tests
private KafkaIdempotentRepository kafkaIdempotentRepository;
@EndpointInject("mock:out")
@@ -48,14 +47,15 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
@Override
protected RoutesBuilder createRouteBuilder() {
+ // Every instance of the repository must use a different topic to guarantee isolation between tests
kafkaIdempotentRepository = new KafkaIdempotentRepository("TEST_NON_EAGER_" + UUID.randomUUID(), getBootstrapServers());
- context.getRegistry().bind("kafkaIdempotentRepository", kafkaIdempotentRepository);
+ context.getRegistry().bind("kafkaIdempotentRepositoryNonEager", kafkaIdempotentRepository);
return new RouteBuilder() {
@Override
public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
- .idempotentRepository("kafkaIdempotentRepository").eager(false).to("mock:out").end();
+ .idempotentRepository("kafkaIdempotentRepositoryNonEager").eager(false).to("mock:out").end();
}
};
}
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
index 58ef86ee7d1..cfb5ddd6006 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
@@ -68,13 +68,13 @@ public class KafkaIdempotentRepositoryPersistenceIT extends BaseEmbeddedKafkaTes
@Override
protected RoutesBuilder createRouteBuilder() {
kafkaIdempotentRepository = new KafkaIdempotentRepository("TEST_PERSISTENCE", getBootstrapServers());
- context.getRegistry().bind("kafkaIdempotentRepository", kafkaIdempotentRepository);
+ context.getRegistry().bind("kafkaIdempotentRepositoryPersistence", kafkaIdempotentRepository);
return new RouteBuilder() {
@Override
public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
- .idempotentRepository("kafkaIdempotentRepository").to("mock:out").end();
+ .idempotentRepository("kafkaIdempotentRepositoryPersistence").to("mock:out").end();
}
};
}
[camel] 03/05: (chores) camel-kafka: reorganized the health tests
Posted by or...@apache.org.
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
commit f8d6cf7afa15aaa4e05e09fbcd7621021a5384dd
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Aug 4 13:47:45 2022 +0200
(chores) camel-kafka: reorganized the health tests
---
.../kafka/integration/{ => health}/KafkaConsumerBadPortHealthCheckIT.java | 0
.../{ => health}/KafkaConsumerBadPortSupervisingHealthCheckIT.java | 0
.../integration/{ => health}/KafkaConsumerUnresolvableHealthCheckIT.java | 0
3 files changed, 0 insertions(+), 0 deletions(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
similarity index 100%
rename from components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortHealthCheckIT.java
rename to components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortHealthCheckIT.java
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
similarity index 100%
rename from components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBadPortSupervisingHealthCheckIT.java
rename to components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerBadPortSupervisingHealthCheckIT.java
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java
similarity index 100%
rename from components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerUnresolvableHealthCheckIT.java
rename to components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/health/KafkaConsumerUnresolvableHealthCheckIT.java