From 9074619914ac711a732d26823a9c3e161580ed15 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Torma=20Krist=C3=B3f?= <tormakristof@tormakristof.eu>
Date: Fri, 22 May 2020 04:34:16 +0200
Subject: [PATCH] queue name

---
 src/Application.kt               | 2 +-
 src/consumer/DatabaseConsumer.kt | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

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?) {