add AccountListener
This commit is contained in:
18
src/main/kotlin/ltd/hlaeja/listener/AccountListener.kt
Normal file
18
src/main/kotlin/ltd/hlaeja/listener/AccountListener.kt
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
package ltd.hlaeja.listener
|
||||||
|
|
||||||
|
import io.github.oshai.kotlinlogging.KotlinLogging
|
||||||
|
import ltd.hlaeja.library.accountRegistry.event.AccountMessage
|
||||||
|
import org.apache.kafka.clients.consumer.ConsumerRecord
|
||||||
|
import org.springframework.kafka.annotation.KafkaListener
|
||||||
|
import org.springframework.stereotype.Component
|
||||||
|
|
||||||
|
val log = KotlinLogging.logger {}
|
||||||
|
|
||||||
|
@Component
|
||||||
|
class AccountListener {
|
||||||
|
|
||||||
|
@KafkaListener(topics = ["account"])
|
||||||
|
fun handleRemoteAccountEvent(record: ConsumerRecord<String, AccountMessage>) {
|
||||||
|
log.trace { "Received event: ${record.key()} for user: ${record.value().userId}" }
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user