You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2019/09/03 20:17:10 UTC
[camel-k-runtime] 06/08: chore(test): remove dependencies on
runtime from camel-k-loader-kotlin
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit 6682fcce7ed25e770e3850b0fb041b0900517cfc
Author: lburgazzoli <lb...@gmail.com>
AuthorDate: Tue Sep 3 14:41:49 2019 +0200
chore(test): remove dependencies on runtime from camel-k-loader-kotlin
---
camel-k-loader-kotlin/pom.xml | 8 +-
.../camel/k/loader/kotlin/dsl/IntegrationTest.kt | 124 +++++++++------------
2 files changed, 54 insertions(+), 78 deletions(-)
diff --git a/camel-k-loader-kotlin/pom.xml b/camel-k-loader-kotlin/pom.xml
index f9e500d..03e9542 100644
--- a/camel-k-loader-kotlin/pom.xml
+++ b/camel-k-loader-kotlin/pom.xml
@@ -78,11 +78,6 @@
<!-- ******************************* -->
<dependency>
- <groupId>org.apache.camel.k</groupId>
- <artifactId>camel-k-runtime-main</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-timer</artifactId>
<scope>test</scope>
@@ -163,6 +158,9 @@
<artifactId>kotlin-maven-plugin</artifactId>
<groupId>org.jetbrains.kotlin</groupId>
<version>${kotlin.version}</version>
+ <configuration>
+ <jvmTarget>${maven.compiler.target}</jvmTarget>
+ </configuration>
<executions>
<execution>
<id>compile</id>
diff --git a/camel-k-loader-kotlin/src/test/kotlin/org/apache/camel/k/loader/kotlin/dsl/IntegrationTest.kt b/camel-k-loader-kotlin/src/test/kotlin/org/apache/camel/k/loader/kotlin/dsl/IntegrationTest.kt
index 7336c7d..8f274e0 100644
--- a/camel-k-loader-kotlin/src/test/kotlin/org/apache/camel/k/loader/kotlin/dsl/IntegrationTest.kt
+++ b/camel-k-loader-kotlin/src/test/kotlin/org/apache/camel/k/loader/kotlin/dsl/IntegrationTest.kt
@@ -20,112 +20,90 @@ import org.apache.camel.Predicate
import org.apache.camel.Processor
import org.apache.camel.component.log.LogComponent
import org.apache.camel.component.seda.SedaComponent
+import org.apache.camel.impl.DefaultCamelContext
import org.apache.camel.k.Runtime
-import org.apache.camel.k.listener.RoutesConfigurer
-import org.apache.camel.k.main.ApplicationRuntime
+import org.apache.camel.k.listener.RoutesConfigurer.forRoutes
import org.apache.camel.model.ModelCamelContext
import org.apache.camel.processor.FatalFallbackErrorHandler
-import org.apache.camel.spi.ExchangeFormatter
import org.apache.camel.support.DefaultHeaderFilterStrategy
import org.assertj.core.api.Assertions.assertThat
import org.junit.jupiter.api.Test
-import java.util.concurrent.atomic.AtomicInteger
-import java.util.concurrent.atomic.AtomicReference
import javax.sql.DataSource
class IntegrationTest {
@Test
fun `load integration with rest`() {
- var runtime = ApplicationRuntime()
- runtime.addListener(RoutesConfigurer.forRoutes("classpath:routes-with-rest.kts"))
- runtime.addListener(Runtime.Phase.Started) { runtime.stop() }
- runtime.run()
-
- assertThat(runtime.camelContext.restConfiguration.host).isEqualTo("my-host")
- assertThat(runtime.camelContext.restConfiguration.port).isEqualTo(9192)
- assertThat(runtime.camelContext.getRestConfiguration("undertow", false).host).isEqualTo("my-undertow-host")
- assertThat(runtime.camelContext.getRestConfiguration("undertow", false).port).isEqualTo(9193)
- assertThat(runtime.camelContext.adapt(ModelCamelContext::class.java).restDefinitions.size).isEqualTo(1)
- assertThat(runtime.camelContext.adapt(ModelCamelContext::class.java).restDefinitions[0].path).isEqualTo("/my/path")
+ val context = DefaultCamelContext()
+ val runtime = Runtime.of(context)
+
+ forRoutes("classpath:routes-with-rest.kts").accept(Runtime.Phase.ConfigureRoutes, runtime)
+
+ assertThat(context.restConfiguration.host).isEqualTo("my-host")
+ assertThat(context.restConfiguration.port).isEqualTo(9192)
+ assertThat(context.getRestConfiguration("undertow", false).host).isEqualTo("my-undertow-host")
+ assertThat(context.getRestConfiguration("undertow", false).port).isEqualTo(9193)
+ assertThat(context.adapt(ModelCamelContext::class.java).restDefinitions.size).isEqualTo(1)
+ assertThat(context.adapt(ModelCamelContext::class.java).restDefinitions[0].path).isEqualTo("/my/path")
}
@Test
fun `load integration with beans`() {
- var runtime = ApplicationRuntime()
- runtime.addListener(RoutesConfigurer.forRoutes("classpath:routes-with-beans.kts"))
- runtime.addListener(Runtime.Phase.Started) { runtime.stop() }
- runtime.run()
-
- assertThat(runtime.camelContext.registry.findByType(DataSource::class.java)).hasSize(1)
- assertThat(runtime.camelContext.registry.lookupByName("dataSource")).isInstanceOf(DataSource::class.java)
- assertThat(runtime.camelContext.registry.findByType(DefaultHeaderFilterStrategy::class.java)).hasSize(1)
- assertThat(runtime.camelContext.registry.lookupByName("filterStrategy")).isInstanceOf(DefaultHeaderFilterStrategy::class.java)
- assertThat(runtime.camelContext.registry.lookupByName("myProcessor")).isInstanceOf(Processor::class.java)
- assertThat(runtime.camelContext.registry.lookupByName("myPredicate")).isInstanceOf(Predicate::class.java)
+ val context = DefaultCamelContext()
+ val runtime = Runtime.of(context)
+
+ forRoutes("classpath:routes-with-beans.kts").accept(Runtime.Phase.ConfigureRoutes, runtime)
+
+ assertThat(context.registry.findByType(DataSource::class.java)).hasSize(1)
+ assertThat(context.registry.lookupByName("dataSource")).isInstanceOf(DataSource::class.java)
+ assertThat(context.registry.findByType(DefaultHeaderFilterStrategy::class.java)).hasSize(1)
+ assertThat(context.registry.lookupByName("filterStrategy")).isInstanceOf(DefaultHeaderFilterStrategy::class.java)
+ assertThat(context.registry.lookupByName("myProcessor")).isInstanceOf(Processor::class.java)
+ assertThat(context.registry.lookupByName("myPredicate")).isInstanceOf(Predicate::class.java)
}
@Test
fun `load integration with binding`() {
- var runtime = ApplicationRuntime()
- runtime.addListener(RoutesConfigurer.forRoutes("classpath:routes-with-bindings.kts"))
- runtime.addListener(Runtime.Phase.Started) { runtime.stop() }
- runtime.run()
+ val context = DefaultCamelContext()
+ val runtime = Runtime.of(context)
+
+ forRoutes("classpath:routes-with-bindings.kts").accept(Runtime.Phase.ConfigureRoutes, runtime)
- assertThat(runtime.camelContext.registry.lookupByName("my-entry")).isEqualTo("myRegistryEntry1")
- assertThat(runtime.camelContext.registry.lookupByName("my-proc")).isInstanceOf(Processor::class.java)
+ assertThat(context.registry.lookupByName("my-entry")).isEqualTo("myRegistryEntry1")
+ assertThat(context.registry.lookupByName("my-proc")).isInstanceOf(Processor::class.java)
}
@Test
fun `load integration with component configuration`() {
- val sedaSize = AtomicInteger()
- val sedaConsumers = AtomicInteger()
- val mySedaSize = AtomicInteger()
- val mySedaConsumers = AtomicInteger()
- val format = AtomicReference<ExchangeFormatter>()
-
- var runtime = ApplicationRuntime()
- runtime.addListener(RoutesConfigurer.forRoutes("classpath:routes-with-component-configuration.kts"))
- runtime.addListener(Runtime.Phase.Started) {
- val seda = runtime.camelContext.getComponent("seda", SedaComponent::class.java)
- val mySeda = runtime.camelContext.getComponent("mySeda", SedaComponent::class.java)
- val log = runtime.camelContext.getComponent("log", LogComponent::class.java)
-
- sedaSize.set(seda!!.queueSize)
- sedaConsumers.set(seda.concurrentConsumers)
- mySedaSize.set(mySeda!!.queueSize)
- mySedaConsumers.set(mySeda.concurrentConsumers)
- format.set(log!!.exchangeFormatter)
-
- runtime.stop()
- }
+ val context = DefaultCamelContext()
+ val runtime = Runtime.of(context)
+
+ forRoutes("classpath:routes-with-component-configuration.kts").accept(Runtime.Phase.ConfigureRoutes, runtime)
- runtime.run()
+ val seda = context.getComponent("seda", SedaComponent::class.java)
+ val mySeda = context.getComponent("mySeda", SedaComponent::class.java)
+ val log = context.getComponent("log", LogComponent::class.java)
- assertThat(sedaSize.get()).isEqualTo(1234)
- assertThat(sedaConsumers.get()).isEqualTo(12)
- assertThat(mySedaSize.get()).isEqualTo(4321)
- assertThat(mySedaConsumers.get()).isEqualTo(21)
- assertThat(format.get()).isNotNull
+ assertThat(seda.queueSize).isEqualTo(1234)
+ assertThat(seda.concurrentConsumers).isEqualTo(12)
+ assertThat(mySeda.queueSize).isEqualTo(4321)
+ assertThat(mySeda.concurrentConsumers).isEqualTo(21)
+ assertThat(log.exchangeFormatter).isNotNull
}
@Test
fun `load integration with error handler`() {
- var onExceptions = mutableListOf<Processor>()
+ val context = DefaultCamelContext()
+ val runtime = Runtime.of(context)
- var runtime = ApplicationRuntime()
- runtime.addListener(RoutesConfigurer.forRoutes("classpath:routes-with-error-handler.kts"))
- runtime.addListener(Runtime.Phase.Started) {
- assertThat(it.camelContext.routes).hasSize(1)
- assertThat(it.camelContext.routes[0].routeContext.getOnException("my-on-exception")).isNotNull
+ forRoutes("classpath:routes-with-error-handler.kts").accept(Runtime.Phase.ConfigureRoutes, runtime)
- onExceptions.add(it.camelContext.routes[0].routeContext.getOnException("my-on-exception"))
+ context.start()
- runtime.stop()
+ try {
+ assertThat(context.routes).hasSize(1)
+ assertThat(context.routes[0].routeContext.getOnException("my-on-exception")).isInstanceOf(FatalFallbackErrorHandler::class.java)
+ } finally {
+ context.stop()
}
-
- runtime.run()
-
- assertThat(onExceptions).hasSize(1)
- assertThat(onExceptions).first().isInstanceOf(FatalFallbackErrorHandler::class.java)
}
}
\ No newline at end of file