@@ -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) {
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user