diff --git a/src/main/kotlin/mq/DatabaseConsumer.kt b/src/main/kotlin/mq/DatabaseConsumer.kt
index fe4a1db..1c8c8fd 100644
--- a/src/main/kotlin/mq/DatabaseConsumer.kt
+++ b/src/main/kotlin/mq/DatabaseConsumer.kt
@@ -30,7 +30,7 @@ class DatabaseConsumer(channel: Channel): Consumer, KoinComponent {
     override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) {
         try {
             val rawJson = body!!.toString(Charsets.UTF_8)
-            val apiObject = Json.decodeFromString<ApiObject>(rawJson)
+            val apiObject = Json{ ignoreUnknownKeys = true }.decodeFromString<ApiObject>(rawJson)
             resultObjectService.addOne(apiObject)
             basicChannel.basicAck(envelope!!.deliveryTag, false)
         } catch (e: Exception) {