| | |
| | | |
| | | import java.util.*; |
| | | |
| | | @SuppressWarnings("rawtypes") |
| | | @Component |
| | | public class RedisCatchStorageImpl implements IRedisCatchStorage { |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void cleanPlatformRegisterInfos() { |
| | | List regInfos = redis.scan(VideoManagerConstants.PLATFORM_REGISTER_INFO_PREFIX + "*"); |
| | | for (Object key : regInfos) { |
| | | redis.del(key.toString()); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void updateSendRTPSever(SendRtpItem sendRtpItem) { |
| | | String key = VideoManagerConstants.PLATFORM_SEND_RTP_INFO_PREFIX + sendRtpItem.getPlatformId() + "_" + sendRtpItem.getChannelId(); |
| | | redis.set(key, sendRtpItem); |