refactoring

pull/1705/head
Nikita Koksharov 6 years ago
parent 3679450650
commit 3b0396ddf5

@ -25,6 +25,7 @@ import java.util.List;
import org.redisson.api.RFuture; import org.redisson.api.RFuture;
import org.redisson.api.RScript; import org.redisson.api.RScript;
import org.redisson.client.codec.Codec; import org.redisson.client.codec.Codec;
import org.redisson.client.codec.StringCodec;
import org.redisson.client.protocol.RedisCommand; import org.redisson.client.protocol.RedisCommand;
import org.redisson.client.protocol.RedisCommands; import org.redisson.client.protocol.RedisCommands;
import org.redisson.command.CommandAsyncExecutor; import org.redisson.command.CommandAsyncExecutor;
@ -63,7 +64,7 @@ public class RedissonScript implements RScript {
@Override @Override
public RFuture<String> scriptLoadAsync(String luaScript) { public RFuture<String> scriptLoadAsync(String luaScript) {
return commandExecutor.writeAllAsync(RedisCommands.SCRIPT_LOAD, new SlotCallback<String, String>() { return commandExecutor.writeAllAsync(StringCodec.INSTANCE, RedisCommands.SCRIPT_LOAD, new SlotCallback<String, String>() {
volatile String result; volatile String result;
@Override @Override
public void onSlotResult(String result) { public void onSlotResult(String result) {
@ -79,7 +80,7 @@ public class RedissonScript implements RScript {
@Override @Override
public RFuture<String> scriptLoadAsync(String key, String luaScript) { public RFuture<String> scriptLoadAsync(String key, String luaScript) {
return commandExecutor.writeAsync(key, RedisCommands.SCRIPT_LOAD, luaScript); return commandExecutor.writeAsync(key, StringCodec.INSTANCE, RedisCommands.SCRIPT_LOAD, luaScript);
} }
@Override @Override

@ -45,7 +45,6 @@ public class RedissonMapCacheTest extends BaseMapTest {
Map<?, ?> map = Deencapsulation.getField(evictionScheduler, "tasks"); Map<?, ?> map = Deencapsulation.getField(evictionScheduler, "tasks");
assertThat(map.isEmpty()).isFalse(); assertThat(map.isEmpty()).isFalse();
cache.destroy(); cache.destroy();
System.out.println("keys: " + map.keySet());
assertThat(map.isEmpty()).isTrue(); assertThat(map.isEmpty()).isTrue();
} }

Loading…
Cancel
Save