Skip to content

Commit a4dfe2d

Browse files
committed
chore: Add logging in user listener in quiz service
1 parent 2d9899b commit a4dfe2d

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

quiz-service/quiz-infra/src/main/kotlin/com/grepp/quizy/quiz/infra/user/messaging/listener/UserEventKafkaListener.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ class UserEventKafkaListener(
2626
ack.acknowledge()
2727
} catch (ex: Exception) {
2828
log.error(ex) { "이벤트 처리 중 오류 발생: $appEvent" }
29-
// ack.acknowledge()를 호출하지 않음으로써 메시지를 재처리 가능하도록 유지
3029
}
3130
}
3231
}

quiz-service/quiz-infra/src/main/kotlin/com/grepp/quizy/quiz/infra/user/messaging/listener/user/UserEventHandler.kt

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,11 @@ import com.grepp.quizy.quiz.domain.user.UserId
66
import com.grepp.quizy.quiz.infra.user.messaging.listener.AbstractEventHandler
77
import com.grepp.quizy.quiz.infra.user.messaging.listener.EventHandler
88
import com.grepp.quizy.quiz.infra.user.messaging.listener.getPayloadAs
9+
import io.github.oshai.kotlinlogging.KotlinLogging
910
import org.springframework.stereotype.Component
1011

12+
private val log = KotlinLogging.logger {}
13+
1114
@Component
1215
class UserEventHandler(
1316
mapper: ObjectMapper,
@@ -20,14 +23,17 @@ class UserEventHandler(
2023
final override fun initActions() {
2124
actions.put(UserEvent.UserEventType.USER_CREATED) { event ->
2225
val userCreatedEvent = event.getPayloadAs<UserCreatedEvent>()
26+
log.info { "User Created Event: $userCreatedEvent" }
2327
quizUserService.createUser(UserId(userCreatedEvent.userId), userCreatedEvent.toProfile())
2428
}
2529
actions.put(UserEvent.UserEventType.USER_UPDATED) { event ->
2630
val userUpdatedEvent = event.getPayloadAs<UserUpdatedEvent>()
31+
log.info { "User Updated Event: $userUpdatedEvent" }
2732
quizUserService.updateUser(UserId(userUpdatedEvent.userId), userUpdatedEvent.toProfile())
2833
}
2934
actions.put(UserEvent.UserEventType.USER_DELETED) { event ->
3035
val userDeletedEvent = event.getPayloadAs<UserDeletedEvent>()
36+
log.info { "User Deleted Event: $userDeletedEvent" }
3137
quizUserService.deleteUser(UserId(userDeletedEvent.userId))
3238
}
3339
}

0 commit comments

Comments
 (0)