Order Processing - Choreography - Inventory Service

inventory_service.kt

class InventoryService(private val inventory: MutableMap<Int, Sku> = mutableMapOf()) {
    @KafkaListener(topics = [SHIPMENTS])
    fun onOrder(order: Order) {

        if (order.status !== SHIPPED) return

        order.items.forEach {
            inventory.computeIfPresent(it) { _, v -> v.decrementStock().also { sku -> sendMessage(SKUS, sku) } }
        }
    }
}