resources/application.conf

@@ -15,7 +15,5 @@ ktor {
         host = ${MQ_HOST}
         username = ${MQ_USERNAME}
         password = ${MQ_PASSWORD}
-        exchange = "output"
-        exchange = ${?MQ_EXCHANGE}
     }
 }

src/Application.kt

@@ -16,6 +16,7 @@ import org.apache.http.HttpException
 import com.kmalbz.database.DatabaseFactory
 import com.kmalbz.database.dao.ResultObjects
 import com.kmalbz.database.service.ResultObjectService
+import com.kmalbz.mq.RecieveOutput
 import io.ktor.util.KtorExperimentalAPI
 import com.rabbitmq.client.*
 import com.typesafe.config.ConfigFactory
@@ -59,11 +60,9 @@ fun Application.module(testing: Boolean = false) {
     val connection = factory.newConnection()
     val channel = connection.createChannel()
 
-    val rabbitExchangeName = appConfig.property("ktor.mq.exchange").getString()
+    channel.exchangeDeclare(RecieveOutput.EXCHANGE_NAME, BuiltinExchangeType.FANOUT)
-
-    channel.exchangeDeclare(rabbitExchangeName, BuiltinExchangeType.FANOUT)
     val queueName = channel.queueDeclare().queue
-    channel.queueBind(queueName, rabbitExchangeName, "")
+    channel.queueBind(queueName, RecieveOutput.EXCHANGE_NAME, "")
 
     GlobalScope.launch(Dispatchers.Default) {
         connection.channel {
@@ -81,6 +80,14 @@ fun Application.module(testing: Boolean = false) {
     }
 
     routing {
+        get("/") {
+            call.respondText("HELLO WORLD!", contentType = ContentType.Text.Plain)
+        }
+
+        get("/json/gson") {
+            call.respond(mapOf("hello" to "world"))
+        }
+
         install(StatusPages) {
             exception<AuthenticationException> { _ ->
                 call.respond(HttpStatusCode.Unauthorized)

src/mq/RecieveOutput.kt

@@ -0,0 +1,7 @@
+package com.kmalbz.mq
+
+class RecieveOutput {
+    companion object {
+        const val EXCHANGE_NAME = "output"
+    }
+}