Skip to content

Commit 4b53160

Browse files
committed
Remove unnecessary Builder and fix merge issue. Fixes #520
1 parent bd19193 commit 4b53160

File tree

4 files changed

+7
-26
lines changed

4 files changed

+7
-26
lines changed

src/main/java/redis/clients/jedis/BuilderFactory.java

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -104,25 +104,6 @@ public String toString() {
104104

105105
};
106106

107-
public static final Builder<Map<String, Long>> STRING_LONG_MAP = new Builder<Map<String, Long>>() {
108-
@SuppressWarnings("unchecked")
109-
public Map<String, Long> build(Object data) {
110-
final List<byte[]> flatHash = (List<byte[]>) data;
111-
final Map<String, Long> hash = new HashMap<String, Long>();
112-
final Iterator<byte[]> iterator = flatHash.iterator();
113-
while (iterator.hasNext()) {
114-
hash.put(SafeEncoder.encode(iterator.next()), Long.valueOf(SafeEncoder.encode(iterator.next())));
115-
}
116-
117-
return hash;
118-
}
119-
120-
public String toString() {
121-
return "Map<String, Long>";
122-
}
123-
124-
};
125-
126107
public static final Builder<Set<String>> STRING_SET = new Builder<Set<String>>() {
127108
@SuppressWarnings("unchecked")
128109
public Set<String> build(Object data) {

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3245,10 +3245,10 @@ public Long pubSubNumPat() {
32453245
return client.getIntegerReply();
32463246
}
32473247

3248-
public Map<String, Long> pubSubNumSub(String... channels) {
3248+
public Map<String, String> pubSubNumSub(String... channels) {
32493249
checkIsInMulti();
32503250
client.pubSubNumSub(channels);
3251-
return BuilderFactory.STRING_LONG_MAP
3251+
return BuilderFactory.STRING_MAP
32523252
.build(client.getBinaryMultiBulkReply());
32533253
}
32543254
}

src/main/java/redis/clients/jedis/Protocol.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ public static final byte[] toByteArray(final double value) {
200200
}
201201

202202
public static enum Command {
203-
PING, SET, GET, QUIT, EXISTS, DEL, TYPE, FLUSHDB, KEYS, RANDOMKEY, RENAME, RENAMENX, RENAMEX, DBSIZE, EXPIRE, EXPIREAT, TTL, SELECT, MOVE, FLUSHALL, GETSET, MGET, SETNX, SETEX, MSET, MSETNX, DECRBY, DECR, INCRBY, INCR, APPEND, SUBSTR, HSET, HGET, HSETNX, HMSET, HMGET, HINCRBY, HEXISTS, HDEL, HLEN, HKEYS, HVALS, HGETALL, RPUSH, LPUSH, LLEN, LRANGE, LTRIM, LINDEX, LSET, LREM, LPOP, RPOP, RPOPLPUSH, SADD, SMEMBERS, SREM, SPOP, SMOVE, SCARD, SISMEMBER, SINTER, SINTERSTORE, SUNION, SUNIONSTORE, SDIFF, SDIFFSTORE, SRANDMEMBER, ZADD, ZRANGE, ZREM, ZINCRBY, ZRANK, ZREVRANK, ZREVRANGE, ZCARD, ZSCORE, MULTI, DISCARD, EXEC, WATCH, UNWATCH, SORT, BLPOP, BRPOP, AUTH, SUBSCRIBE, PUBLISH, UNSUBSCRIBE, PSUBSCRIBE, PUNSUBSCRIBE, ZCOUNT, ZRANGEBYSCORE, ZREVRANGEBYSCORE, ZREMRANGEBYRANK, ZREMRANGEBYSCORE, ZUNIONSTORE, ZINTERSTORE, SAVE, BGSAVE, BGREWRITEAOF, LASTSAVE, SHUTDOWN, INFO, MONITOR, SLAVEOF, CONFIG, STRLEN, SYNC, LPUSHX, PERSIST, RPUSHX, ECHO, LINSERT, DEBUG, BRPOPLPUSH, SETBIT, GETBIT, SETRANGE, GETRANGE, EVAL, EVALSHA, SCRIPT, SLOWLOG, OBJECT, BITCOUNT, BITOP, SENTINEL, DUMP, RESTORE, PEXPIRE, PEXPIREAT, PTTL, INCRBYFLOAT, PSETEX, CLIENT, TIME, MIGRATE, HINCRBYFLOAT, SCAN, HSCAN, SSCAN, ZSCAN, WAIT, CLUSTER, ASKING;
203+
PING, SET, GET, QUIT, EXISTS, DEL, TYPE, FLUSHDB, KEYS, RANDOMKEY, RENAME, RENAMENX, RENAMEX, DBSIZE, EXPIRE, EXPIREAT, TTL, SELECT, MOVE, FLUSHALL, GETSET, MGET, SETNX, SETEX, MSET, MSETNX, DECRBY, DECR, INCRBY, INCR, APPEND, SUBSTR, HSET, HGET, HSETNX, HMSET, HMGET, HINCRBY, HEXISTS, HDEL, HLEN, HKEYS, HVALS, HGETALL, RPUSH, LPUSH, LLEN, LRANGE, LTRIM, LINDEX, LSET, LREM, LPOP, RPOP, RPOPLPUSH, SADD, SMEMBERS, SREM, SPOP, SMOVE, SCARD, SISMEMBER, SINTER, SINTERSTORE, SUNION, SUNIONSTORE, SDIFF, SDIFFSTORE, SRANDMEMBER, ZADD, ZRANGE, ZREM, ZINCRBY, ZRANK, ZREVRANK, ZREVRANGE, ZCARD, ZSCORE, MULTI, DISCARD, EXEC, WATCH, UNWATCH, SORT, BLPOP, BRPOP, AUTH, SUBSCRIBE, PUBLISH, UNSUBSCRIBE, PSUBSCRIBE, PUNSUBSCRIBE, PUBSUB, ZCOUNT, ZRANGEBYSCORE, ZREVRANGEBYSCORE, ZREMRANGEBYRANK, ZREMRANGEBYSCORE, ZUNIONSTORE, ZINTERSTORE, SAVE, BGSAVE, BGREWRITEAOF, LASTSAVE, SHUTDOWN, INFO, MONITOR, SLAVEOF, CONFIG, STRLEN, SYNC, LPUSHX, PERSIST, RPUSHX, ECHO, LINSERT, DEBUG, BRPOPLPUSH, SETBIT, GETBIT, SETRANGE, GETRANGE, EVAL, EVALSHA, SCRIPT, SLOWLOG, OBJECT, BITCOUNT, BITOP, SENTINEL, DUMP, RESTORE, PEXPIRE, PEXPIREAT, PTTL, INCRBYFLOAT, PSETEX, CLIENT, TIME, MIGRATE, HINCRBYFLOAT, SCAN, HSCAN, SSCAN, ZSCAN, WAIT, CLUSTER, ASKING;
204204

205205
public final byte[] raw;
206206

src/test/java/redis/clients/jedis/tests/commands/PublishSubscribeCommandsTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -145,9 +145,9 @@ public void onMessage(String channel, String message) {
145145

146146
@Test
147147
public void pubSubNumSub(){
148-
final Map<String, Long> expectedNumSub = new HashMap<String, Long>();
149-
expectedNumSub.put("testchannel2", 1l);
150-
expectedNumSub.put("testchannel1", 1l);
148+
final Map<String, String> expectedNumSub = new HashMap<String, String>();
149+
expectedNumSub.put("testchannel2", "1");
150+
expectedNumSub.put("testchannel1", "1");
151151
jedis.subscribe(new JedisPubSub() {
152152
private int count=0;
153153
@Override
@@ -159,7 +159,7 @@ public void onSubscribe(String channel, int subscribedChannels) {
159159
count++;
160160
if (count == 2) {
161161
Jedis otherJedis = createJedis();
162-
Map<String, Long> numSub = otherJedis.pubSubNumSub("testchannel1", "testchannel2");
162+
Map<String, String> numSub = otherJedis.pubSubNumSub("testchannel1", "testchannel2");
163163
assertEquals(expectedNumSub, numSub);
164164
unsubscribe();
165165
}

0 commit comments

Comments
 (0)