Class ThreadTransferTimeoutConfig
java.lang.Object
com.bytedesk.service.thread_transfer.ThreadTransferTimeoutConfig
会话转接超时Redis监听器配置
用于监听Redis key过期事件,自动处理转接超时
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
configureKeyspaceNotifications
(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) 自动配置Redis keyspace notificationsprivate String
解释Redis keyspace notifications配置的含义private boolean
检查是否有真实的转接记录private void
startHealthCheck
(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) 启动健康检查,确保配置生效private void
测试监听器功能是否正常org.springframework.data.redis.listener.RedisMessageListenerContainer
threadTransferTimeoutListenerContainer
(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) 创建Redis消息监听器容器
-
Field Details
-
timeoutService
-
-
Constructor Details
-
ThreadTransferTimeoutConfig
-
-
Method Details
-
threadTransferTimeoutListenerContainer
@Bean("threadTransferTimeoutListenerContainer") @DependsOn("threadTransferTimeoutService") public org.springframework.data.redis.listener.RedisMessageListenerContainer threadTransferTimeoutListenerContainer(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) 创建Redis消息监听器容器- Parameters:
connectionFactory
- Redis连接工厂- Returns:
- Redis消息监听器容器
-
configureKeyspaceNotifications
private void configureKeyspaceNotifications(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) 自动配置Redis keyspace notifications- Parameters:
connectionFactory
- Redis连接工厂
-
startHealthCheck
private void startHealthCheck(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) 启动健康检查,确保配置生效- Parameters:
connectionFactory
- Redis连接工厂
-
explainKeyspaceNotificationsConfig
解释Redis keyspace notifications配置的含义- Parameters:
config
- 配置值- Returns:
- 配置说明
-
testListenerFunctionality
private void testListenerFunctionality()测试监听器功能是否正常 -
hasRealTransferRecords
private boolean hasRealTransferRecords()检查是否有真实的转接记录- Returns:
- true if has real transfer records
-