Skip to content

Commit ec82045

Browse files
s-sathishmarcosnils
s-sathish
authored and
marcosnils
committed
Added support for georadius_ro, georadiusbymember_ro commands (#1841)
* Add SSL support to JedisCluster (#1550) * Add SSL support to JedisCluster * Remove unused imports from SSLJedisClusterTest * Add JedisClusterPortMap interface for mapping between plaintext and SSL ports. * Fix casing in JedisClusterPortMap * Add new constructor for JedisClusterInfoCache instead of modifying existing one to fix backwards compatibility issue * Undo unintended formatting changes. * Improve name of test case in SSLJedisClusterTest * Fix logic for closing JedisCluster objects in SSLJedisClusterTest * Add option to specify mapping between redis and ssl hostnames * Remove unneeded public access modifiers * Support for geo RO commands. * Support for geo RO commands. * Support for geo RO commands. * Change _ro to Readonly for better understanding. * Change _ro to Readonly for better understanding Update as per comments * Change _ro to Readonly for better understanding Update as per comments * Minor update. Update commands. https://redis.io/commands/georadius * Update as per comments. * Revert "Add SSL support to JedisCluster (#1550)" This reverts commit 17901ba.
1 parent 43482e8 commit ec82045

16 files changed

+480
-2
lines changed

‎src/main/java/redis/clients/jedis/BinaryClient.java‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1321,21 +1321,41 @@ public void georadius(final byte[] key, final double longitude, final double lat
13211321
unit.raw);
13221322
}
13231323

1324+
public void georadiusReadonly(final byte[] key, final double longitude, final double latitude, final double radius, final GeoUnit unit) {
1325+
sendCommand(GEORADIUS_RO, key, toByteArray(longitude), toByteArray(latitude), toByteArray(radius),
1326+
unit.raw);
1327+
}
1328+
13241329
public void georadius(final byte[] key, final double longitude, final double latitude, final double radius, final GeoUnit unit,
13251330
final GeoRadiusParam param) {
13261331
sendCommand(GEORADIUS, param.getByteParams(key, toByteArray(longitude), toByteArray(latitude),
13271332
toByteArray(radius), unit.raw));
13281333
}
13291334

1335+
public void georadiusReadonly(final byte[] key, final double longitude, final double latitude, final double radius, final GeoUnit unit,
1336+
final GeoRadiusParam param) {
1337+
sendCommand(GEORADIUS_RO, param.getByteParams(key, toByteArray(longitude), toByteArray(latitude),
1338+
toByteArray(radius), unit.raw));
1339+
}
1340+
13301341
public void georadiusByMember(final byte[] key, final byte[] member, final double radius, final GeoUnit unit) {
13311342
sendCommand(GEORADIUSBYMEMBER, key, member, toByteArray(radius), unit.raw);
13321343
}
13331344

1345+
public void georadiusByMemberReadonly(final byte[] key, final byte[] member, final double radius, final GeoUnit unit) {
1346+
sendCommand(GEORADIUSBYMEMBER_RO, key, member, toByteArray(radius), unit.raw);
1347+
}
1348+
13341349
public void georadiusByMember(final byte[] key, final byte[] member, final double radius, final GeoUnit unit,
13351350
final GeoRadiusParam param) {
13361351
sendCommand(GEORADIUSBYMEMBER, param.getByteParams(key, member, toByteArray(radius), unit.raw));
13371352
}
13381353

1354+
public void georadiusByMemberReadonly(final byte[] key, final byte[] member, final double radius, final GeoUnit unit,
1355+
final GeoRadiusParam param) {
1356+
sendCommand(GEORADIUSBYMEMBER_RO, param.getByteParams(key, member, toByteArray(radius), unit.raw));
1357+
}
1358+
13391359
private ArrayList<byte[]> convertScoreMembersToByteArrays(final Map<byte[], Double> scoreMembers) {
13401360
ArrayList<byte[]> args = new ArrayList<byte[]>(scoreMembers.size() * 2);
13411361

‎src/main/java/redis/clients/jedis/BinaryJedis.java‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3793,6 +3793,14 @@ public List<GeoRadiusResponse> georadius(final byte[] key, final double longitud
37933793
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
37943794
}
37953795

3796+
@Override
3797+
public List<GeoRadiusResponse> georadiusReadonly(final byte[] key, final double longitude, final double latitude,
3798+
final double radius, final GeoUnit unit) {
3799+
checkIsInMultiOrPipeline();
3800+
client.georadiusReadonly(key, longitude, latitude, radius, unit);
3801+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3802+
}
3803+
37963804
@Override
37973805
public List<GeoRadiusResponse> georadius(final byte[] key, final double longitude, final double latitude,
37983806
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
@@ -3801,6 +3809,14 @@ public List<GeoRadiusResponse> georadius(final byte[] key, final double longitud
38013809
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
38023810
}
38033811

3812+
@Override
3813+
public List<GeoRadiusResponse> georadiusReadonly(final byte[] key, final double longitude, final double latitude,
3814+
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
3815+
checkIsInMultiOrPipeline();
3816+
client.georadiusReadonly(key, longitude, latitude, radius, unit, param);
3817+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3818+
}
3819+
38043820
@Override
38053821
public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[] member, final double radius,
38063822
final GeoUnit unit) {
@@ -3809,6 +3825,14 @@ public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[]
38093825
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
38103826
}
38113827

3828+
@Override
3829+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final byte[] key, final byte[] member, final double radius,
3830+
final GeoUnit unit) {
3831+
checkIsInMultiOrPipeline();
3832+
client.georadiusByMemberReadonly(key, member, radius, unit);
3833+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3834+
}
3835+
38123836
@Override
38133837
public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[] member, final double radius,
38143838
final GeoUnit unit, final GeoRadiusParam param) {
@@ -3817,6 +3841,14 @@ public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[]
38173841
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
38183842
}
38193843

3844+
@Override
3845+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final byte[] key, final byte[] member, final double radius,
3846+
final GeoUnit unit, final GeoRadiusParam param) {
3847+
checkIsInMultiOrPipeline();
3848+
client.georadiusByMemberReadonly(key, member, radius, unit, param);
3849+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3850+
}
3851+
38203852
/**
38213853
* A decorator to implement Set from List. Assume that given List do not contains duplicated
38223854
* values. The resulting set displays the same ordering, concurrency, and performance

‎src/main/java/redis/clients/jedis/BinaryJedisCluster.java‎

Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2061,6 +2061,17 @@ public List<GeoRadiusResponse> execute(Jedis connection) {
20612061
}.runBinary(key);
20622062
}
20632063

2064+
@Override
2065+
public List<GeoRadiusResponse> georadiusReadonly(final byte[] key, final double longitude,
2066+
final double latitude, final double radius, final GeoUnit unit) {
2067+
return new JedisClusterCommand<List<GeoRadiusResponse>>(connectionHandler, maxAttempts) {
2068+
@Override
2069+
public List<GeoRadiusResponse> execute(Jedis connection) {
2070+
return connection.georadiusReadonly(key, longitude, latitude, radius, unit);
2071+
}
2072+
}.runBinary(key);
2073+
}
2074+
20642075
@Override
20652076
public List<GeoRadiusResponse> georadius(final byte[] key, final double longitude,
20662077
final double latitude, final double radius, final GeoUnit unit, final GeoRadiusParam param) {
@@ -2072,6 +2083,17 @@ public List<GeoRadiusResponse> execute(Jedis connection) {
20722083
}.runBinary(key);
20732084
}
20742085

2086+
@Override
2087+
public List<GeoRadiusResponse> georadiusReadonly(final byte[] key, final double longitude,
2088+
final double latitude, final double radius, final GeoUnit unit, final GeoRadiusParam param) {
2089+
return new JedisClusterCommand<List<GeoRadiusResponse>>(connectionHandler, maxAttempts) {
2090+
@Override
2091+
public List<GeoRadiusResponse> execute(Jedis connection) {
2092+
return connection.georadiusReadonly(key, longitude, latitude, radius, unit, param);
2093+
}
2094+
}.runBinary(key);
2095+
}
2096+
20752097
@Override
20762098
public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[] member,
20772099
final double radius, final GeoUnit unit) {
@@ -2083,6 +2105,17 @@ public List<GeoRadiusResponse> execute(Jedis connection) {
20832105
}.runBinary(key);
20842106
}
20852107

2108+
@Override
2109+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final byte[] key, final byte[] member,
2110+
final double radius, final GeoUnit unit) {
2111+
return new JedisClusterCommand<List<GeoRadiusResponse>>(connectionHandler, maxAttempts) {
2112+
@Override
2113+
public List<GeoRadiusResponse> execute(Jedis connection) {
2114+
return connection.georadiusByMemberReadonly(key, member, radius, unit);
2115+
}
2116+
}.runBinary(key);
2117+
}
2118+
20862119
@Override
20872120
public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[] member,
20882121
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
@@ -2094,6 +2127,17 @@ public List<GeoRadiusResponse> execute(Jedis connection) {
20942127
}.runBinary(key);
20952128
}
20962129

2130+
@Override
2131+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final byte[] key, final byte[] member,
2132+
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
2133+
return new JedisClusterCommand<List<GeoRadiusResponse>>(connectionHandler, maxAttempts) {
2134+
@Override
2135+
public List<GeoRadiusResponse> execute(Jedis connection) {
2136+
return connection.georadiusByMemberReadonly(key, member, radius, unit, param);
2137+
}
2138+
}.runBinary(key);
2139+
}
2140+
20972141
@Override
20982142
public Set<byte[]> keys(final byte[] pattern) {
20992143
if (pattern == null || pattern.length == 0) {

‎src/main/java/redis/clients/jedis/BinaryJedisClusterCommands.java‎

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -271,14 +271,25 @@ Set<byte[]> zrevrangeByLex(byte[] key, byte[] max, byte[] min, int offset,
271271
List<GeoRadiusResponse> georadius(byte[] key, double longitude, double latitude, double radius,
272272
GeoUnit unit);
273273

274+
List<GeoRadiusResponse> georadiusReadonly(byte[] key, double longitude, double latitude, double radius,
275+
GeoUnit unit);
276+
274277
List<GeoRadiusResponse> georadius(byte[] key, double longitude, double latitude, double radius,
275278
GeoUnit unit, GeoRadiusParam param);
276279

280+
List<GeoRadiusResponse> georadiusReadonly(byte[] key, double longitude, double latitude, double radius,
281+
GeoUnit unit, GeoRadiusParam param);
282+
277283
List<GeoRadiusResponse> georadiusByMember(byte[] key, byte[] member, double radius, GeoUnit unit);
278284

285+
List<GeoRadiusResponse> georadiusByMemberReadonly(byte[] key, byte[] member, double radius, GeoUnit unit);
286+
279287
List<GeoRadiusResponse> georadiusByMember(byte[] key, byte[] member, double radius, GeoUnit unit,
280288
GeoRadiusParam param);
281289

290+
List<GeoRadiusResponse> georadiusByMemberReadonly(byte[] key, byte[] member, double radius, GeoUnit unit,
291+
GeoRadiusParam param);
292+
282293
/**
283294
* @deprecated Use {@link MultiKeyBinaryJedisClusterCommands#scan(byte[], redis.clients.jedis.ScanParams)}
284295
*/

‎src/main/java/redis/clients/jedis/BinaryJedisCommands.java‎

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -296,14 +296,25 @@ Set<byte[]> zrevrangeByLex(byte[] key, byte[] max, byte[] min, int offset,
296296
List<GeoRadiusResponse> georadius(byte[] key, double longitude, double latitude, double radius,
297297
GeoUnit unit);
298298

299+
List<GeoRadiusResponse> georadiusReadonly(byte[] key, double longitude, double latitude, double radius,
300+
GeoUnit unit);
301+
299302
List<GeoRadiusResponse> georadius(byte[] key, double longitude, double latitude, double radius,
300303
GeoUnit unit, GeoRadiusParam param);
301304

305+
List<GeoRadiusResponse> georadiusReadonly(byte[] key, double longitude, double latitude, double radius,
306+
GeoUnit unit, GeoRadiusParam param);
307+
302308
List<GeoRadiusResponse> georadiusByMember(byte[] key, byte[] member, double radius, GeoUnit unit);
303309

310+
List<GeoRadiusResponse> georadiusByMemberReadonly(byte[] key, byte[] member, double radius, GeoUnit unit);
311+
304312
List<GeoRadiusResponse> georadiusByMember(byte[] key, byte[] member, double radius, GeoUnit unit,
305313
GeoRadiusParam param);
306314

315+
List<GeoRadiusResponse> georadiusByMemberReadonly(byte[] key, byte[] member, double radius, GeoUnit unit,
316+
GeoRadiusParam param);
317+
307318
ScanResult<Map.Entry<byte[], byte[]>> hscan(byte[] key, byte[] cursor);
308319

309320
ScanResult<Map.Entry<byte[], byte[]>> hscan(byte[] key, byte[] cursor, ScanParams params);

‎src/main/java/redis/clients/jedis/BinaryRedisPipeline.java‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -270,15 +270,27 @@ Response<Set<byte[]>> zrevrangeByLex(byte[] key, byte[] max, byte[] min,
270270
Response<List<GeoRadiusResponse>> georadius(byte[] key, double longitude, double latitude,
271271
double radius, GeoUnit unit);
272272

273+
Response<List<GeoRadiusResponse>> georadiusReadonly(byte[] key, double longitude, double latitude,
274+
double radius, GeoUnit unit);
275+
273276
Response<List<GeoRadiusResponse>> georadius(byte[] key, double longitude, double latitude,
274277
double radius, GeoUnit unit, GeoRadiusParam param);
275278

279+
Response<List<GeoRadiusResponse>> georadiusReadonly(byte[] key, double longitude, double latitude,
280+
double radius, GeoUnit unit, GeoRadiusParam param);
281+
276282
Response<List<GeoRadiusResponse>> georadiusByMember(byte[] key, byte[] member, double radius,
277283
GeoUnit unit);
278284

285+
Response<List<GeoRadiusResponse>> georadiusByMemberReadonly(byte[] key, byte[] member, double radius,
286+
GeoUnit unit);
287+
279288
Response<List<GeoRadiusResponse>> georadiusByMember(byte[] key, byte[] member, double radius,
280289
GeoUnit unit, GeoRadiusParam param);
281290

291+
Response<List<GeoRadiusResponse>> georadiusByMemberReadonly(byte[] key, byte[] member, double radius,
292+
GeoUnit unit, GeoRadiusParam param);
293+
282294
Response<List<Long>> bitfield(byte[] key, byte[]... elements);
283295

284296
Response<Long> hstrlen(byte[] key, byte[] field);

‎src/main/java/redis/clients/jedis/BinaryShardedJedis.java‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -895,27 +895,55 @@ public List<GeoRadiusResponse> georadius(final byte[] key, final double longitud
895895
return j.georadius(key, longitude, latitude, radius, unit);
896896
}
897897

898+
@Override
899+
public List<GeoRadiusResponse> georadiusReadonly(final byte[] key, final double longitude, final double latitude,
900+
final double radius, final GeoUnit unit) {
901+
Jedis j = getShard(key);
902+
return j.georadiusReadonly(key, longitude, latitude, radius, unit);
903+
}
904+
898905
@Override
899906
public List<GeoRadiusResponse> georadius(final byte[] key, final double longitude, final double latitude,
900907
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
901908
Jedis j = getShard(key);
902909
return j.georadius(key, longitude, latitude, radius, unit, param);
903910
}
904911

912+
@Override
913+
public List<GeoRadiusResponse> georadiusReadonly(final byte[] key, final double longitude, final double latitude,
914+
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
915+
Jedis j = getShard(key);
916+
return j.georadiusReadonly(key, longitude, latitude, radius, unit, param);
917+
}
918+
905919
@Override
906920
public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[] member, final double radius,
907921
final GeoUnit unit) {
908922
Jedis j = getShard(key);
909923
return j.georadiusByMember(key, member, radius, unit);
910924
}
911925

926+
@Override
927+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final byte[] key, final byte[] member, final double radius,
928+
final GeoUnit unit) {
929+
Jedis j = getShard(key);
930+
return j.georadiusByMemberReadonly(key, member, radius, unit);
931+
}
932+
912933
@Override
913934
public List<GeoRadiusResponse> georadiusByMember(final byte[] key, final byte[] member, final double radius,
914935
final GeoUnit unit, final GeoRadiusParam param) {
915936
Jedis j = getShard(key);
916937
return j.georadiusByMember(key, member, radius, unit, param);
917938
}
918939

940+
@Override
941+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final byte[] key, final byte[] member, final double radius,
942+
final GeoUnit unit, final GeoRadiusParam param) {
943+
Jedis j = getShard(key);
944+
return j.georadiusByMemberReadonly(key, member, radius, unit, param);
945+
}
946+
919947
@Override
920948
public ScanResult<Map.Entry<byte[], byte[]>> hscan(final byte[] key, final byte[] cursor) {
921949
Jedis j = getShard(key);

‎src/main/java/redis/clients/jedis/Client.java‎

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1153,15 +1153,33 @@ public void georadius(final String key, final double longitude, final double lat
11531153
georadius(SafeEncoder.encode(key), longitude, latitude, radius, unit);
11541154
}
11551155

1156+
public void georadiusReadonly(final String key, final double longitude, final double latitude, final double radius, final GeoUnit unit) {
1157+
georadiusReadonly(SafeEncoder.encode(key), longitude, latitude, radius, unit);
1158+
}
1159+
11561160
public void georadius(final String key, final double longitude, final double latitude, final double radius, final GeoUnit unit,
11571161
final GeoRadiusParam param) {
11581162
georadius(SafeEncoder.encode(key), longitude, latitude, radius, unit, param);
11591163
}
11601164

1165+
public void georadiusReadonly(final String key, final double longitude, final double latitude, final double radius, final GeoUnit unit,
1166+
final GeoRadiusParam param) {
1167+
georadiusReadonly(SafeEncoder.encode(key), longitude, latitude, radius, unit, param);
1168+
}
1169+
11611170
public void georadiusByMember(final String key, final String member, final double radius, final GeoUnit unit) {
11621171
georadiusByMember(SafeEncoder.encode(key), SafeEncoder.encode(member), radius, unit);
11631172
}
11641173

1174+
public void georadiusByMemberReadonly(final String key, final String member, final double radius, final GeoUnit unit) {
1175+
georadiusByMemberReadonly(SafeEncoder.encode(key), SafeEncoder.encode(member), radius, unit);
1176+
}
1177+
1178+
public void georadiusByMemberReadonly(final String key, final String member, final double radius, final GeoUnit unit,
1179+
final GeoRadiusParam param) {
1180+
georadiusByMemberReadonly(SafeEncoder.encode(key), SafeEncoder.encode(member), radius, unit, param);
1181+
}
1182+
11651183
public void georadiusByMember(final String key, final String member, final double radius, final GeoUnit unit,
11661184
final GeoRadiusParam param) {
11671185
georadiusByMember(SafeEncoder.encode(key), SafeEncoder.encode(member), radius, unit, param);

‎src/main/java/redis/clients/jedis/Jedis.java‎

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3716,6 +3716,14 @@ public List<GeoRadiusResponse> georadius(final String key, final double longitud
37163716
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
37173717
}
37183718

3719+
@Override
3720+
public List<GeoRadiusResponse> georadiusReadonly(final String key, final double longitude, final double latitude,
3721+
final double radius, final GeoUnit unit) {
3722+
checkIsInMultiOrPipeline();
3723+
client.georadiusReadonly(key, longitude, latitude, radius, unit);
3724+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3725+
}
3726+
37193727
@Override
37203728
public List<GeoRadiusResponse> georadius(final String key, final double longitude, final double latitude,
37213729
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
@@ -3724,6 +3732,14 @@ public List<GeoRadiusResponse> georadius(final String key, final double longitud
37243732
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
37253733
}
37263734

3735+
@Override
3736+
public List<GeoRadiusResponse> georadiusReadonly(final String key, final double longitude, final double latitude,
3737+
final double radius, final GeoUnit unit, final GeoRadiusParam param) {
3738+
checkIsInMultiOrPipeline();
3739+
client.georadiusReadonly(key, longitude, latitude, radius, unit, param);
3740+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3741+
}
3742+
37273743
@Override
37283744
public List<GeoRadiusResponse> georadiusByMember(final String key, final String member, final double radius,
37293745
final GeoUnit unit) {
@@ -3732,6 +3748,22 @@ public List<GeoRadiusResponse> georadiusByMember(final String key, final String
37323748
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
37333749
}
37343750

3751+
@Override
3752+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final String key, final String member, final double radius,
3753+
final GeoUnit unit, final GeoRadiusParam param) {
3754+
checkIsInMultiOrPipeline();
3755+
client.georadiusByMemberReadonly(key, member, radius, unit, param);
3756+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3757+
}
3758+
3759+
@Override
3760+
public List<GeoRadiusResponse> georadiusByMemberReadonly(final String key, final String member, final double radius,
3761+
final GeoUnit unit) {
3762+
checkIsInMultiOrPipeline();
3763+
client.georadiusByMemberReadonly(key, member, radius, unit);
3764+
return BuilderFactory.GEORADIUS_WITH_PARAMS_RESULT.build(client.getObjectMultiBulkReply());
3765+
}
3766+
37353767
@Override
37363768
public List<GeoRadiusResponse> georadiusByMember(final String key, final String member, final double radius,
37373769
final GeoUnit unit, final GeoRadiusParam param) {

0 commit comments

Comments
 (0)