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 <angusyo...@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();
}
};
}
