Commit 257d661d authored by zhuyunfeng's avatar zhuyunfeng Committed by liaozan

add cache keys

parent 411eb589
...@@ -13,6 +13,7 @@ import org.springframework.core.env.Environment; ...@@ -13,6 +13,7 @@ import org.springframework.core.env.Environment;
import java.time.Duration; import java.time.Duration;
import java.util.*; import java.util.*;
import java.util.Map.Entry; import java.util.Map.Entry;
import java.util.stream.Collectors;
/** /**
* @author liaozan * @author liaozan
...@@ -64,7 +65,13 @@ public class CacheProviderDelegate implements CacheProvider { ...@@ -64,7 +65,13 @@ public class CacheProviderDelegate implements CacheProvider {
@Override @Override
public Set<String> keys(String pattern) { public Set<String> keys(String pattern) {
return getCacheProvider().keys(withKeyPrefix(pattern)); Set<String> keys = getCacheProvider().keys(withKeyPrefix(pattern));
return keys.stream().map(e->{
if(StringUtils.isBlank(prefixWithDelimiter)){
return e;
}
return e.replaceFirst(prefixWithDelimiter,"");
}).collect(Collectors.toSet());
} }
@Override @Override
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment