add find system by type method

Adven27 · Oct 18, 2021 · 0c3b78b · 0c3b78b
1 parent fbb5e8f
commit 0c3b78b
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/env-core/src/main/java/io/github/adven27/env/core/Environment.kt b/env-core/src/main/java/io/github/adven27/env/core/Environment.kt
@@ -102,8 +102,8 @@ open class Environment @JvmOverloads constructor(
             "\n\n ==================================================\n\n"
 
     @Suppress("UNCHECKED_CAST")
-    fun <T : ExternalSystem> find(name: String): T = (systems[name] ?: error("System $name not found")) as T
-    inline fun <reified T : ExternalSystem> find() = systems.values.filterIsInstance<T>().single()
+    fun <T : ExternalSystem> env(name: String): T = (systems[name] ?: error("System $name not found")) as T
+    inline fun <reified T : ExternalSystem> env() = systems.values.filterIsInstance<T>().single()
 
     companion object : KLogging() {
         private fun start(

diff --git a/...fka-embedded/src/main/java/io/github/adven27/env/mq/kafka/embedded/EmbeddedKafkaSystem.kt b/...fka-embedded/src/main/java/io/github/adven27/env/mq/kafka/embedded/EmbeddedKafkaSystem.kt
@@ -31,7 +31,7 @@ open class EmbeddedKafkaSystem(
             CONTROLLED_SHUTDOWN,
             NUMBER_OF_PARTITIONS,
             *topics
-        ).brokerProperties(properties),
+        ).brokerProperties(mapOf("group.initial.rebalance.delay.ms" to "0") + properties),
         defaultPort
     )
 

diff --git a/...bedded/src/test/kotlin/io/github/adven27/env/mq/kafka/embedded/EmbeddedKafkaSystemTest.kt b/...bedded/src/test/kotlin/io/github/adven27/env/mq/kafka/embedded/EmbeddedKafkaSystemTest.kt
@@ -25,5 +25,5 @@ class EmbeddedKafkaSystemTest {
 }
 
 class SomeEnvironment : Environment("EMBEDDED_KAFKA" to EmbeddedKafkaSystem("some-topic")) {
-    fun kafka() = find<EmbeddedKafkaSystem>()
+    fun kafka() = env<EmbeddedKafkaSystem>()
 }
diff --git a/example/src/test/kotlin/EnvTest.kt b/example/src/test/kotlin/EnvTest.kt
@@ -61,6 +61,6 @@ class SomeEnvironment : Environment(
     },
     "WIREMOCK" to WiremockSystem()
 ) {
-    fun rabbit() = find<RabbitContainerSystem>()
-    fun postgres() = find<PostgreSqlContainerSystem>()
+    fun rabbit() = env<RabbitContainerSystem>()
+    fun postgres() = env<PostgreSqlContainerSystem>()
 }