diff --git a/redisson/src/main/java/org/redisson/RedissonGeo.java b/redisson/src/main/java/org/redisson/RedissonGeo.java index 444d776c4..1377941cb 100644 --- a/redisson/src/main/java/org/redisson/RedissonGeo.java +++ b/redisson/src/main/java/org/redisson/RedissonGeo.java @@ -30,6 +30,7 @@ import org.redisson.api.RGeo; import org.redisson.api.RedissonClient; import org.redisson.client.codec.Codec; import org.redisson.client.codec.LongCodec; +import org.redisson.client.codec.StringCodec; import org.redisson.client.protocol.RedisCommand; import org.redisson.client.protocol.RedisCommands; import org.redisson.client.protocol.decoder.CodecDecoder; @@ -91,7 +92,7 @@ public class RedissonGeo extends RedissonScoredSortedSet implements RGeo extends RedissonScoredSortedSet implements RGeo distAsync(V firstMember, V secondMember, GeoUnit geoUnit) { - return commandExecutor.readAsync(getName(), codec, RedisCommands.GEODIST, getName(), encode(firstMember), encode(secondMember), geoUnit); + return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, RedisCommands.GEODIST, getName(), encode(firstMember), encode(secondMember), geoUnit); } @Override @@ -117,7 +118,7 @@ public class RedissonGeo extends RedissonScoredSortedSet implements RGeo> command = new RedisCommand>("GEOHASH", new MapGetAllDecoder((List)Arrays.asList(members), 0)); - return commandExecutor.readAsync(getName(), codec, command, params.toArray()); + return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, command, params.toArray()); } @Override @@ -135,7 +136,7 @@ public class RedissonGeo extends RedissonScoredSortedSet implements RGeo> decoder = new ListMultiDecoder(new GeoPositionDecoder(), new ObjectListReplayDecoder(ListMultiDecoder.RESET), new GeoPositionMapDecoder((List)Arrays.asList(members))); RedisCommand> command = new RedisCommand>("GEOPOS", decoder); - return commandExecutor.readAsync(getName(), codec, command, params.toArray()); + return commandExecutor.readAsync(getName(), StringCodec.INSTANCE, command, params.toArray()); } @Override