diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java index 20aa9e5..8cbad9a 100644 --- a/src/main/java/redis/clients/jedis/Pipeline.java +++ b/src/main/java/redis/clients/jedis/Pipeline.java @@ -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 unformatted = client.getAll(); List formatted = new ArrayList(); for (Object o : unformatted) { - formatted.add(generateResponse(o).get()); + try{ + formatted.add(generateResponse(o).get()); + }catch(JedisDataException e){ + formatted.add(e); + } } return formatted; }