refactoring

pull/1827/head
Nikita Koksharov 6 years ago
parent e89cce3b3e
commit b0afc60755

@ -324,7 +324,7 @@ public class RedissonConnection extends AbstractRedisConnection {
} }
Set<byte[]> results = new HashSet<byte[]>(); Set<byte[]> results = new HashSet<byte[]>();
RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, KEYS, pattern)); RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern));
return sync(f); return sync(f);
} }

@ -326,7 +326,7 @@ public class RedissonConnection extends AbstractRedisConnection {
} }
Set<byte[]> results = new HashSet<byte[]>(); Set<byte[]> results = new HashSet<byte[]>();
RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, KEYS, pattern)); RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern));
return sync(f); return sync(f);
} }

@ -335,7 +335,7 @@ public class RedissonConnection extends AbstractRedisConnection {
} }
Set<byte[]> results = new HashSet<byte[]>(); Set<byte[]> results = new HashSet<byte[]>();
RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, KEYS, pattern)); RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern));
return sync(f); return sync(f);
} }

@ -336,7 +336,7 @@ public class RedissonConnection extends AbstractRedisConnection {
} }
Set<byte[]> results = new HashSet<byte[]>(); Set<byte[]> results = new HashSet<byte[]>();
RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, KEYS, pattern)); RFuture<Set<byte[]>> f = (RFuture<Set<byte[]>>)(Object)(executorService.readAllAsync(results, StringCodec.INSTANCE, KEYS, pattern));
return sync(f); return sync(f);
} }

@ -165,7 +165,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
" return 1;" + " return 1;" +
"end;" + "end;" +
"return 0; ", "return 0; ",
Arrays.<Object>asList(getName(key), getTimeoutSetNameByKey(key), getIdleSetNameByKey(key), getLastAccessTimeSetNameByKey(key), getOptionsName(key)), Arrays.<Object>asList(getName(key), getTimeoutSetNameByKey(key), getIdleSetNameByKey(key), getLastAccessTimeSetNameByKey(key), getOptionsNameByKey(key)),
System.currentTimeMillis(), encodeMapKey(key)); System.currentTimeMillis(), encodeMapKey(key));
} }

Loading…
Cancel
Save