diff --git a/src/main/kotlin/mq/DatabaseConsumer.kt b/src/main/kotlin/mq/DatabaseConsumer.kt
index d0c69a1..1127a32 100644
--- a/src/main/kotlin/mq/DatabaseConsumer.kt
+++ b/src/main/kotlin/mq/DatabaseConsumer.kt
@@ -10,18 +10,21 @@ import database.service.ISampleObjectService
 import org.koin.core.component.KoinComponent
 import org.koin.core.component.inject
 
-class DatabaseConsumer: Consumer, KoinComponent {
-    private val resultObjectService : ISampleObjectService by inject()
+class DatabaseConsumer : Consumer, KoinComponent {
+    private val resultObjectService: ISampleObjectService by inject()
     private val gson = Gson()
-    override fun handleConsumeOk(consumerTag : String?) {
+    override fun handleConsumeOk(consumerTag: String?) {
     }
-    override fun handleCancelOk(p0 : String?) {
+
+    override fun handleCancelOk(p0: String?) {
         throw UnsupportedOperationException()
     }
-    override fun handleRecoverOk(p0 : String?) {
+
+    override fun handleRecoverOk(p0: String?) {
         throw UnsupportedOperationException()
     }
-    override fun handleCancel(p0 : String?) {
+
+    override fun handleCancel(p0: String?) {
         throw UnsupportedOperationException()
     }
 
@@ -29,9 +32,18 @@ class DatabaseConsumer: Consumer, KoinComponent {
         println("got shutdown signal")
     }
 
-    override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) {
-        val rawJson = body!!.toString(Charsets.UTF_8)
-        val apiObject = gson.fromJson(rawJson, ApiObject::class.java)
-        resultObjectService.addOne(apiObject)
+    override fun handleDelivery(
+        consumerTag: String?,
+        envelope: Envelope?,
+        basicProperties: AMQP.BasicProperties?,
+        body: ByteArray?
+    ) {
+        try {
+            val rawJson = body!!.toString(Charsets.UTF_8)
+            val apiObject = gson.fromJson(rawJson, ApiObject::class.java)
+            resultObjectService.addOne(apiObject)
+        } catch (e: Exception) {
+            println(e.stackTrace)
         }
+    }
 }
\ No newline at end of file