|
@@ -147,7 +147,9 @@ public class ImRoomOperator {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public void close(){
|
|
public void close(){
|
|
|
- atomicLong.expire(Duration.of(3, ChronoUnit.DAYS));
|
|
|
|
|
|
|
+ if(atomicLong!=null){
|
|
|
|
|
+ atomicLong.expire(Duration.of(3, ChronoUnit.DAYS));
|
|
|
|
|
+ }
|
|
|
msgKeyFilter.expire(Duration.of(3, ChronoUnit.DAYS));
|
|
msgKeyFilter.expire(Duration.of(3, ChronoUnit.DAYS));
|
|
|
unReadMap.forEach((k,bitSet)->{
|
|
unReadMap.forEach((k,bitSet)->{
|
|
|
bitSet.expire(Duration.of(30, ChronoUnit.DAYS));
|
|
bitSet.expire(Duration.of(30, ChronoUnit.DAYS));
|