examples-spring-redis-amq

1
package com.tasks.cache.service
2

3
import org.redisson.api.RedissonClient
4
import org.redisson.client.codec.StringCodec
5
import org.springframework.stereotype.Service
6

7

8
@Service
9
class SubscribeInitializer(redissonClient: RedissonClient, expireMessageListener: ExpireMessageListener) {
10

11
    init {
12
        redissonClient.getTopic("__keyevent@0__:expired", StringCodec.INSTANCE)
13
                .addListener(String::class.java, expireMessageListener)
14
    }
15

16
}