This commit is contained in:
parent
ce1aa81dbd
commit
bb69905ede
@ -38,7 +38,7 @@ class DatabaseConsumer (channel: Channel) : Consumer, KoinComponent {
|
|||||||
) {
|
) {
|
||||||
try {
|
try {
|
||||||
val rawJson = body!!.toString(Charsets.UTF_8)
|
val rawJson = body!!.toString(Charsets.UTF_8)
|
||||||
val apiObject = Json.decodeFromString<ApiObject>(rawJson)
|
val apiObject = Json{ ignoreUnknownKeys = true }.decodeFromString<ApiObject>(rawJson)
|
||||||
resultObjectService.addOne(apiObject)
|
resultObjectService.addOne(apiObject)
|
||||||
basicChannel.basicAck(envelope!!.deliveryTag,false)
|
basicChannel.basicAck(envelope!!.deliveryTag,false)
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
|
Loading…
Reference in New Issue
Block a user