Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Lettuce zCount/zInterStore ops executing synchronously while in pipeline

Browse Source 
DATAREDIS-140
This commit is contained in:
Jennifer Hickey
2013-04-01 10:22:33 -07:00
parent a40555ed19
commit 97ebd34b2d
2 changed files with 3 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java
View File

@@ -1321,7 +1321,7 @@ public class LettuceConnection implements RedisConnection {
public Long zCount(byte[] key, double min, double max) {
try {
if (isQueueing()) {
if (isPipelined()) {
pipeline(asyncConn.zcount(key, min, max));
return null;
}
@@ -1347,7 +1347,7 @@ public class LettuceConnection implements RedisConnection {
ZStoreArgs storeArgs = LettuceUtils.zArgs(aggregate, weights);
try {
if (isQueueing()) {
if (isPipelined()) {
pipeline(asyncConn.zinterstore(destKey, storeArgs, sets));
return null;
}
@@ -1360,7 +1360,7 @@ public class LettuceConnection implements RedisConnection {
public Long zInterStore(byte[] destKey, byte[]... sets) {
try {
if (isQueueing()) {
if (isPipelined()) {
pipeline(asyncConn.zinterstore(destKey, sets));
return null;
}