src/Application.kt

@@ -54,7 +54,7 @@ fun Application.module() {
     val queueName = channel.queueDeclare().queue
     channel.queueBind(queueName, rabbitExchangeName, "")
 
-    channel.basicConsume(rabbitExchangeName, true, DatabaseConsumer())
+    channel.basicConsume(queueName, true, DatabaseConsumer())
 
     routing {
         install(StatusPages) {

src/consumer/DatabaseConsumer.kt

@@ -9,9 +9,9 @@ import com.rabbitmq.client.Envelope
 import com.rabbitmq.client.ShutdownSignalException
 
 class DatabaseConsumer : Consumer {
-    val resultObjectService = ResultObjectService()
+    private val resultObjectService = ResultObjectService()
 
-    val gson = Gson()
+    private val gson = Gson()
     override fun handleConsumeOk(consumerTag : String?) {
     }
     override fun handleCancelOk(p0 : String?) {