| | |
| | | package com.genersoft.iot.vmp.gb28181.event.offline;
|
| | |
|
| | | import org.slf4j.Logger;
|
| | | import org.slf4j.LoggerFactory;
|
| | | import org.springframework.beans.factory.annotation.Autowired;
|
| | | import org.springframework.data.redis.connection.Message;
|
| | | import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
|
| | |
| | | */
|
| | | @Component
|
| | | public class KeepliveTimeoutListener extends KeyExpirationEventMessageListener {
|
| | |
|
| | | private Logger logger = LoggerFactory.getLogger(KeepliveTimeoutListener.class);
|
| | |
|
| | | @Autowired
|
| | | private EventPublisher publisher;
|
| | |
| | | // 获取失效的key
|
| | | String expiredKey = message.toString();
|
| | | if(!expiredKey.startsWith(VideoManagerConstants.KEEPLIVEKEY_PREFIX)){
|
| | | System.out.println("收到redis过期监听,但开头不是"+VideoManagerConstants.KEEPLIVEKEY_PREFIX+",忽略");
|
| | | logger.debug("收到redis过期监听,但开头不是"+VideoManagerConstants.KEEPLIVEKEY_PREFIX+",忽略");
|
| | | return;
|
| | | }
|
| | |
|