#13 Add ability to specify consul port

Add enabled toggle for route and consul service
laviua · Feb 6, 2017 · 4cfedee · 4cfedee
1 parent 0bc4c99
commit 4cfedee
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 2 deletions.
diff --git a/gradle.properties b/gradle.properties
@@ -1 +1 @@
-version=1.1.1
+version=1.1.2
diff --git a/komock-core/mock_example.yml b/komock-core/mock_example.yml
@@ -1,6 +1,7 @@
 consul:
   enabled: false
   consulHost: 127.0.0.1
+  consulPort: 8500
   services:
     -
       serviceId: customer-data-service

diff --git a/komock-core/src/main/kotlin/ua/com/lavi/komock/config/property/consul/ConsulProperties.kt b/komock-core/src/main/kotlin/ua/com/lavi/komock/config/property/consul/ConsulProperties.kt
@@ -9,10 +9,12 @@ import java.util.*
 class ConsulServerProperties {
     var enabled: Boolean = false
     var consulHost = "localhost"
+    var consulPort = 8500
     var services = ArrayList<ConsulServiceProperties>()
 }
 
 class ConsulServiceProperties {
+    var enabled: Boolean = true
     var serviceId: String = "defaultConsulService"
     var serviceName: String = "defaultConsulServiceName"
     var servicePort: Int = 8080

diff --git a/komock-core/src/main/kotlin/ua/com/lavi/komock/config/property/http/RouteProperties.kt b/komock-core/src/main/kotlin/ua/com/lavi/komock/config/property/http/RouteProperties.kt
@@ -8,6 +8,7 @@ import java.util.*
  */
 
 class RouteProperties {
+    var enabled: Boolean = true
     var httpMethod: String = ""
     var url: String = ""
     var contentType: String = ""

diff --git a/komock-core/src/main/kotlin/ua/com/lavi/komock/registrar/ConsulRegistrar.kt b/komock-core/src/main/kotlin/ua/com/lavi/komock/registrar/ConsulRegistrar.kt
@@ -14,7 +14,7 @@ class ConsulRegistrar {
     private val log = LoggerFactory.getLogger(this.javaClass)
 
     fun register(consulServerProperties: ConsulServerProperties) {
-        val clientRegistrar = ConsulClient(consulServerProperties.consulHost)
+        val clientRegistrar = ConsulClient(consulServerProperties.consulHost, consulServerProperties.consulPort)
         log.debug("Found: ${consulServerProperties.services.size} consul services")
         for (consulService in consulServerProperties.services) {
             val newService = NewService()