diff --git a/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index c855eb548..624733f9c 100644 --- a/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -1989,7 +1989,7 @@ public class RedissonConnection extends AbstractRedisConnection { @Override public GeoResults> geoRadius(byte[] key, Circle within) { - RedisCommand>> command = new RedisCommand>>("GEORADIUS", new GeoResultsDecoder()); + RedisCommand>> command = new RedisCommand>>("GEORADIUS_RO", new GeoResultsDecoder()); return read(key, ByteArrayCodec.INSTANCE, command, key, convert(within.getCenter().getX()), convert(within.getCenter().getY()), within.getRadius().getValue(), getAbbreviation(within.getRadius().getMetric())); @@ -2006,11 +2006,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUS", postitionDecoder); + command = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(within.getRadius().getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUS", distanceDecoder); + command = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -2037,7 +2037,7 @@ public class RedissonConnection extends AbstractRedisConnection { return geoRadiusByMember(key, member, new Distance(radius, DistanceUnit.METERS)); } - private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER", new GeoResultsDecoder()); + private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER_RO", new GeoResultsDecoder()); @Override public GeoResults> geoRadiusByMember(byte[] key, byte[] member, Distance radius) { @@ -2055,11 +2055,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(radius.getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 75bafae89..373753cad 100644 --- a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -1980,7 +1980,7 @@ public class RedissonConnection extends AbstractRedisConnection { @Override public GeoResults> geoRadius(byte[] key, Circle within) { - RedisCommand>> command = new RedisCommand>>("GEORADIUS", new GeoResultsDecoder()); + RedisCommand>> command = new RedisCommand>>("GEORADIUS_RO", new GeoResultsDecoder()); return read(key, ByteArrayCodec.INSTANCE, command, key, convert(within.getCenter().getX()), convert(within.getCenter().getY()), within.getRadius().getValue(), getAbbreviation(within.getRadius().getMetric())); @@ -1997,11 +1997,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUS", postitionDecoder); + command = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(within.getRadius().getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUS", distanceDecoder); + command = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -2028,7 +2028,7 @@ public class RedissonConnection extends AbstractRedisConnection { return geoRadiusByMember(key, member, new Distance(radius, DistanceUnit.METERS)); } - private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER", new GeoResultsDecoder()); + private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER_RO", new GeoResultsDecoder()); @Override public GeoResults> geoRadiusByMember(byte[] key, byte[] member, Distance radius) { @@ -2046,11 +2046,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(radius.getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java index 8d217f2f9..4cf26e638 100644 --- a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java +++ b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java @@ -161,11 +161,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUS", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUS", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -203,11 +203,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 4e1888c40..eb35e76f1 100644 --- a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -2011,7 +2011,7 @@ public class RedissonConnection extends AbstractRedisConnection { @Override public GeoResults> geoRadius(byte[] key, Circle within) { - RedisCommand>> command = new RedisCommand>>("GEORADIUS", new GeoResultsDecoder()); + RedisCommand>> command = new RedisCommand>>("GEORADIUS_RO", new GeoResultsDecoder()); return read(key, ByteArrayCodec.INSTANCE, command, key, convert(within.getCenter().getX()), convert(within.getCenter().getY()), within.getRadius().getValue(), getAbbreviation(within.getRadius().getMetric())); @@ -2028,11 +2028,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUS", postitionDecoder); + command = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(within.getRadius().getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUS", distanceDecoder); + command = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -2059,7 +2059,7 @@ public class RedissonConnection extends AbstractRedisConnection { return geoRadiusByMember(key, member, new Distance(radius, DistanceUnit.METERS)); } - private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER", new GeoResultsDecoder()); + private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER_RO", new GeoResultsDecoder()); @Override public GeoResults> geoRadiusByMember(byte[] key, byte[] member, Distance radius) { @@ -2077,11 +2077,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(radius.getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java index 8d217f2f9..4cf26e638 100644 --- a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java +++ b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java @@ -161,11 +161,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUS", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUS", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -203,11 +203,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index c55c9ce9f..476e6a0e4 100644 --- a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -2003,7 +2003,7 @@ public class RedissonConnection extends AbstractRedisConnection { @Override public GeoResults> geoRadius(byte[] key, Circle within) { - RedisCommand>> command = new RedisCommand>>("GEORADIUS", new GeoResultsDecoder()); + RedisCommand>> command = new RedisCommand>>("GEORADIUS_RO", new GeoResultsDecoder()); return read(key, ByteArrayCodec.INSTANCE, command, key, convert(within.getCenter().getX()), convert(within.getCenter().getY()), within.getRadius().getValue(), getAbbreviation(within.getRadius().getMetric())); @@ -2020,11 +2020,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUS", postitionDecoder); + command = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(within.getRadius().getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUS", distanceDecoder); + command = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -2051,7 +2051,7 @@ public class RedissonConnection extends AbstractRedisConnection { return geoRadiusByMember(key, member, new Distance(radius, DistanceUnit.METERS)); } - private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER", new GeoResultsDecoder()); + private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER_RO", new GeoResultsDecoder()); @Override public GeoResults> geoRadiusByMember(byte[] key, byte[] member, Distance radius) { @@ -2069,11 +2069,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(radius.getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java index 8d217f2f9..4cf26e638 100644 --- a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java +++ b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java @@ -161,11 +161,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUS", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUS", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -203,11 +203,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 42b201ed5..9ef40c359 100644 --- a/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -1980,7 +1980,7 @@ public class RedissonConnection extends AbstractRedisConnection { @Override public GeoResults> geoRadius(byte[] key, Circle within) { - RedisCommand>> command = new RedisCommand>>("GEORADIUS", new GeoResultsDecoder()); + RedisCommand>> command = new RedisCommand>>("GEORADIUS_RO", new GeoResultsDecoder()); return read(key, ByteArrayCodec.INSTANCE, command, key, convert(within.getCenter().getX()), convert(within.getCenter().getY()), within.getRadius().getValue(), getAbbreviation(within.getRadius().getMetric())); @@ -1997,11 +1997,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUS", postitionDecoder); + command = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(within.getRadius().getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUS", distanceDecoder); + command = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -2028,7 +2028,7 @@ public class RedissonConnection extends AbstractRedisConnection { return geoRadiusByMember(key, member, new Distance(radius, DistanceUnit.METERS)); } - private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER", new GeoResultsDecoder()); + private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER_RO", new GeoResultsDecoder()); @Override public GeoResults> geoRadiusByMember(byte[] key, byte[] member, Distance radius) { @@ -2046,11 +2046,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(radius.getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java b/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java index 8d217f2f9..4cf26e638 100644 --- a/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java +++ b/redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java @@ -161,11 +161,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUS", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUS", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -203,11 +203,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java index 42b201ed5..9ef40c359 100644 --- a/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java +++ b/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java @@ -1980,7 +1980,7 @@ public class RedissonConnection extends AbstractRedisConnection { @Override public GeoResults> geoRadius(byte[] key, Circle within) { - RedisCommand>> command = new RedisCommand>>("GEORADIUS", new GeoResultsDecoder()); + RedisCommand>> command = new RedisCommand>>("GEORADIUS_RO", new GeoResultsDecoder()); return read(key, ByteArrayCodec.INSTANCE, command, key, convert(within.getCenter().getX()), convert(within.getCenter().getY()), within.getRadius().getValue(), getAbbreviation(within.getRadius().getMetric())); @@ -1997,11 +1997,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUS", postitionDecoder); + command = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(within.getRadius().getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUS", distanceDecoder); + command = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -2028,7 +2028,7 @@ public class RedissonConnection extends AbstractRedisConnection { return geoRadiusByMember(key, member, new Distance(radius, DistanceUnit.METERS)); } - private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER", new GeoResultsDecoder()); + private static final RedisCommand>> GEORADIUSBYMEMBER = new RedisCommand>>("GEORADIUSBYMEMBER_RO", new GeoResultsDecoder()); @Override public GeoResults> geoRadiusByMember(byte[] key, byte[] member, Distance radius) { @@ -2046,11 +2046,11 @@ public class RedissonConnection extends AbstractRedisConnection { RedisCommand>> command; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - command = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new GeoResultsDecoder(radius.getMetric()), new GeoDistanceDecoder()); - command = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + command = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); } diff --git a/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java b/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java index 8d217f2f9..4cf26e638 100644 --- a/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java +++ b/redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonReactiveGeoCommands.java @@ -161,11 +161,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUS", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUS", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUS_RO", distanceDecoder); params.add("WITHDIST"); } @@ -203,11 +203,11 @@ public class RedissonReactiveGeoCommands extends RedissonBaseReactive implements RedisCommand>> cmd; if (args.getFlags().contains(GeoRadiusCommandArgs.Flag.WITHCOORD)) { - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", postitionDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", postitionDecoder); params.add("WITHCOORD"); } else { MultiDecoder>> distanceDecoder = new ListMultiDecoder2(new ByteBufferGeoResultsDecoder(command.getDistance().getMetric()), new GeoDistanceDecoder()); - cmd = new RedisCommand>>("GEORADIUSBYMEMBER", distanceDecoder); + cmd = new RedisCommand>>("GEORADIUSBYMEMBER_RO", distanceDecoder); params.add("WITHDIST"); }