Skip to content

Commit 4ab54d9

Browse files
committed
Change pubSub to pubsub
1 parent 4b53160 commit 4ab54d9

File tree

4 files changed

+18
-18
lines changed

4 files changed

+18
-18
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -561,7 +561,7 @@ public void punsubscribe(final byte[]... patterns) {
561561
sendCommand(PUNSUBSCRIBE, patterns);
562562
}
563563

564-
public void pubSub(final byte[]... args) {
564+
public void pubsub(final byte[]... args) {
565565
sendCommand(PUBSUB, args);
566566
}
567567
public void zcount(final byte[] key, final double min, final double max) {

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -673,16 +673,16 @@ public void subscribe(final String... channels) {
673673
subscribe(cs);
674674
}
675675

676-
public void pubSubChannels(String pattern) {
677-
pubSub(Protocol.PUBSUB_CHANNELS, pattern);
676+
public void pubsubChannels(String pattern) {
677+
pubsub(Protocol.PUBSUB_CHANNELS, pattern);
678678
}
679679

680-
public void pubSubNumPat() {
681-
pubSub(Protocol.PUBSUB_NUM_PAT);
680+
public void pubsubNumPat() {
681+
pubsub(Protocol.PUBSUB_NUM_PAT);
682682
}
683683

684-
public void pubSubNumSub(String... channels) {
685-
pubSub(Protocol.PUBSUB_NUMSUB, channels);
684+
public void pubsubNumSub(String... channels) {
685+
pubsub(Protocol.PUBSUB_NUMSUB, channels);
686686
}
687687

688688
public void configSet(String parameter, String value) {
@@ -854,13 +854,13 @@ public void cluster(final String subcommand, final int... args) {
854854
cluster(arg);
855855
}
856856

857-
public void pubSub(final String subcommand, final String... args) {
857+
public void pubsub(final String subcommand, final String... args) {
858858
final byte[][] arg = new byte[args.length+1][];
859859
for (int i = 1; i < arg.length; i++) {
860860
arg[i] = SafeEncoder.encode(args[i-1]);
861861
}
862862
arg[0] = SafeEncoder.encode(subcommand);
863-
pubSub(arg);
863+
pubsub(arg);
864864
}
865865

866866
public void cluster(final String subcommand, final String... args) {

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3233,21 +3233,21 @@ public String asking() {
32333233
return client.getStatusCodeReply();
32343234
}
32353235

3236-
public List<String> pubSubChannels(String pattern) {
3236+
public List<String> pubsubChannels(String pattern) {
32373237
checkIsInMulti();
3238-
client.pubSubChannels(pattern);
3238+
client.pubsubChannels(pattern);
32393239
return client.getMultiBulkReply();
32403240
}
32413241

3242-
public Long pubSubNumPat() {
3242+
public Long pubsubNumPat() {
32433243
checkIsInMulti();
3244-
client.pubSubNumPat();
3244+
client.pubsubNumPat();
32453245
return client.getIntegerReply();
32463246
}
32473247

3248-
public Map<String, String> pubSubNumSub(String... channels) {
3248+
public Map<String, String> pubsubNumSub(String... channels) {
32493249
checkIsInMulti();
3250-
client.pubSubNumSub(channels);
3250+
client.pubsubNumSub(channels);
32513251
return BuilderFactory.STRING_MAP
32523252
.build(client.getBinaryMultiBulkReply());
32533253
}

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public void onSubscribe(String channel, int subscribedChannels) {
8282
//All channels are subscribed
8383
if (count == 3) {
8484
Jedis otherJedis = createJedis();
85-
List<String> activeChannels = otherJedis.pubSubChannels("test*");
85+
List<String> activeChannels = otherJedis.pubsubChannels("test*");
8686
assertTrue(expectedActiveChannels.containsAll(activeChannels));
8787
unsubscribe();
8888
}
@@ -127,7 +127,7 @@ public void onPSubscribe(String pattern, int subscribedChannels) {
127127
count++;
128128
if (count == 3) {
129129
Jedis otherJedis = createJedis();
130-
Long numPatterns = otherJedis.pubSubNumPat();
130+
Long numPatterns = otherJedis.pubsubNumPat();
131131
assertEquals(new Long(2l), numPatterns);
132132
punsubscribe();
133133
}
@@ -159,7 +159,7 @@ public void onSubscribe(String channel, int subscribedChannels) {
159159
count++;
160160
if (count == 2) {
161161
Jedis otherJedis = createJedis();
162-
Map<String, String> 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)