diff --git a/src/main/kotlin/mq/DatabaseConsumer.kt b/src/main/kotlin/mq/DatabaseConsumer.kt index b6dbd0d..67ea740 100644 --- a/src/main/kotlin/mq/DatabaseConsumer.kt +++ b/src/main/kotlin/mq/DatabaseConsumer.kt @@ -38,7 +38,7 @@ class DatabaseConsumer (channel: Channel) : Consumer, KoinComponent { ) { try { val rawJson = body!!.toString(Charsets.UTF_8) - val apiObject = Json.decodeFromString(rawJson) + val apiObject = Json{ ignoreUnknownKeys = true }.decodeFromString(rawJson) resultObjectService.addOne(apiObject) basicChannel.basicAck(envelope!!.deliveryTag,false) } catch (e: Exception) {