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 2017/03/03 19:36:35 UTC
[12/14] camel git commit: Polished
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 <da...@apache.org>
Authored: Fri Mar 3 20:10:51 2017 +0100
Committer: Claus Ibsen <da...@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