diff --git a/src/Application.kt b/src/Application.kt
index 06293d2..bc4f6e8 100644
--- a/src/Application.kt
+++ b/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) {
diff --git a/src/consumer/DatabaseConsumer.kt b/src/consumer/DatabaseConsumer.kt
index 7ac76da..3b446a2 100644
--- a/src/consumer/DatabaseConsumer.kt
+++ b/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?) {