fixing Issue 188 - Pipline.syncAndReturnAll changes

This commit is contained in:
Vladimir Soskov
2011-07-31 20:28:51 -07:00
parent 22d4d3fc53
commit ec0b58e183

View File

@@ -6,6 +6,7 @@ import java.util.Map;
import java.util.Set;
import redis.clients.jedis.BinaryClient.LIST_POSITION;
import redis.clients.jedis.exceptions.JedisDataException;
public class Pipeline extends Queable {
private Client client;
@@ -39,7 +40,11 @@ public class Pipeline extends Queable {
List<Object> unformatted = client.getAll();
List<Object> formatted = new ArrayList<Object>();
for (Object o : unformatted) {
formatted.add(generateResponse(o).get());
try{
formatted.add(generateResponse(o).get());
}catch(JedisDataException e){
formatted.add(e);
}
}
return formatted;
}