Polished
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/96cc1ce8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/96cc1ce8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/96cc1ce8 Branch: refs/heads/master Commit: 96cc1ce8ea16c6b44d13da19917c6e99f26a0f9b Parents: e76bc31 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Mar 3 20:10:51 2017 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Mar 3 20:10:51 2017 +0100 ---------------------------------------------------------------------- .../kafka/KafkaIdempotentRepositoryEagerTest.java | 12 +++++------- .../kafka/KafkaIdempotentRepositoryNonEagerTest.java | 12 +++++------- 2 files changed, 10 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/96cc1ce8/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerTest.java index 7d9593f..c1c1449 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerTest.java @@ -16,7 +16,6 @@ */ package org.apache.camel.processor.idempotent.kafka; -import org.apache.camel.CamelContext; import org.apache.camel.CamelExecutionException; import org.apache.camel.EndpointInject; import org.apache.camel.RoutesBuilder; @@ -24,8 +23,7 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kafka.embedded.EmbeddedKafkaBroker; import org.apache.camel.component.kafka.embedded.EmbeddedZookeeper; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.impl.DefaultCamelContext; -import org.apache.camel.impl.SimpleRegistry; +import org.apache.camel.impl.JndiRegistry; import org.apache.camel.test.junit4.CamelTestSupport; import org.junit.Rule; import org.junit.Test; @@ -50,13 +48,13 @@ public class KafkaIdempotentRepositoryEagerTest extends CamelTestSupport { private MockEndpoint mockBefore; @Override - protected CamelContext createCamelContext() throws Exception { - SimpleRegistry registry = new SimpleRegistry(); + protected JndiRegistry createRegistry() throws Exception { + JndiRegistry jndi = super.createRegistry(); kafkaIdempotentRepository = new KafkaIdempotentRepository("TEST_IDEM", kafkaBroker.getBrokerList()); - registry.put("kafkaIdempotentRepository", kafkaIdempotentRepository); + jndi.bind("kafkaIdempotentRepository", kafkaIdempotentRepository); - return new DefaultCamelContext(registry); + return jndi; } @Override http://git-wip-us.apache.org/repos/asf/camel/blob/96cc1ce8/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerTest.java index bd4c660..88bf087 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerTest.java @@ -16,7 +16,6 @@ */ package org.apache.camel.processor.idempotent.kafka; -import org.apache.camel.CamelContext; import org.apache.camel.CamelExecutionException; import org.apache.camel.EndpointInject; import org.apache.camel.RoutesBuilder; @@ -24,8 +23,7 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kafka.embedded.EmbeddedKafkaBroker; import org.apache.camel.component.kafka.embedded.EmbeddedZookeeper; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.impl.DefaultCamelContext; -import org.apache.camel.impl.SimpleRegistry; +import org.apache.camel.impl.JndiRegistry; import org.apache.camel.test.junit4.CamelTestSupport; import org.junit.Rule; import org.junit.Test; @@ -50,13 +48,13 @@ public class KafkaIdempotentRepositoryNonEagerTest extends CamelTestSupport { private MockEndpoint mockBefore; @Override - protected CamelContext createCamelContext() throws Exception { - SimpleRegistry registry = new SimpleRegistry(); + protected JndiRegistry createRegistry() throws Exception { + JndiRegistry jndi = super.createRegistry(); kafkaIdempotentRepository = new KafkaIdempotentRepository("TEST_IDEM", kafkaBroker.getBrokerList()); - registry.put("kafkaIdempotentRepository", kafkaIdempotentRepository); + jndi.bind("kafkaIdempotentRepository", kafkaIdempotentRepository); - return new DefaultCamelContext(registry); + return jndi; } @Override
