diff --git a/src/main/java/com/redislabs/redistimeseries/MultiRangeParams.java b/src/main/java/com/redislabs/redistimeseries/MultiRangeParams.java index c5bba7d..1e3621c 100644 --- a/src/main/java/com/redislabs/redistimeseries/MultiRangeParams.java +++ b/src/main/java/com/redislabs/redistimeseries/MultiRangeParams.java @@ -52,13 +52,13 @@ public byte[][] getByteParams(Long from, Long to, String... filters) { List params = new ArrayList<>(); if (from == null) { - params.add("-".getBytes()); + params.add(RedisTimeSeries.MINUS); } else { params.add(Protocol.toByteArray(from)); } if (to == null) { - params.add("+".getBytes()); + params.add(RedisTimeSeries.PLUS); } else { params.add(Protocol.toByteArray(to)); } diff --git a/src/main/java/com/redislabs/redistimeseries/RedisTimeSeries.java b/src/main/java/com/redislabs/redistimeseries/RedisTimeSeries.java index 7a06c70..a8c5446 100644 --- a/src/main/java/com/redislabs/redistimeseries/RedisTimeSeries.java +++ b/src/main/java/com/redislabs/redistimeseries/RedisTimeSeries.java @@ -17,6 +17,8 @@ public class RedisTimeSeries implements AutoCloseable { private static final byte[] STAR = SafeEncoder.encode("*"); + protected static final byte[] PLUS = SafeEncoder.encode("+"); + protected static final byte[] MINUS = SafeEncoder.encode("-"); private final Pool pool;