File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed
src/main/kotlin/org/gitanimals/supports/deadletter Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -6,6 +6,7 @@ import org.gitanimals.core.redis.TraceableMessageListener
66import org.gitanimals.supports.event.SlackInteracted
77import org.gitanimals.supports.event.SlackReplied
88import org.rooftop.netx.api.DeadLetterRelay
9+ import org.slf4j.LoggerFactory
910import org.springframework.beans.factory.annotation.Value
1011import org.springframework.context.ApplicationEventPublisher
1112import org.springframework.data.redis.connection.Message
@@ -21,6 +22,8 @@ class DeadLetterRelayEventListener(
2122 @Value(" \$ {relay.approve.token}" ) private val approveToken : String ,
2223) : TraceableMessageListener(redisTemplate, objectMapper) {
2324
25+ private val logger = LoggerFactory .getLogger(this ::class .simpleName)
26+
2427 override fun onMessage (message : Message ) {
2528 runCatching {
2629 val slackInteracted = objectMapper.readValue(
@@ -53,6 +56,8 @@ class DeadLetterRelayEventListener(
5356 message = " Relay by ${slackInteracted.username} "
5457 )
5558 )
59+ }.onFailure {
60+ logger.error(" Fail to relay dead letter. message: \" $message \" , cause: \" ${it.message} \" " , it)
5661 }
5762 }
5863
You can’t perform that action at this time.
0 commit comments