diff options
| author | Harkrishn Patro <30795839+hpatro@users.noreply.github.com> | 2022-01-03 01:54:47 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-01-02 16:54:47 -0800 |
| commit | 9f8885760b53e6d3952b9c9b41f9e6c48dfa6cec (patch) | |
| tree | 770dfdbff19a1a2a1c71a642ebd844d592ef3d26 /src/redis-cli.c | |
| parent | b8ba942ac2aabf51fd96134d9fa21b47d3baff4a (diff) | |
| download | redis-9f8885760b53e6d3952b9c9b41f9e6c48dfa6cec.tar.gz | |
Sharded pubsub implementation (#8621)
This commit implements a sharded pubsub implementation based off of shard channels.
Co-authored-by: Harkrishn Patro <harkrisp@amazon.com>
Co-authored-by: Madelyn Olson <madelyneolson@gmail.com>
Diffstat (limited to 'src/redis-cli.c')
| -rw-r--r-- | src/redis-cli.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/redis-cli.c b/src/redis-cli.c index 397e3bfa8..94697f99f 100644 --- a/src/redis-cli.c +++ b/src/redis-cli.c @@ -1381,7 +1381,8 @@ static int cliSendCommand(int argc, char **argv, long repeat) { if (!strcasecmp(command,"shutdown")) config.shutdown = 1; if (!strcasecmp(command,"monitor")) config.monitor_mode = 1; if (!strcasecmp(command,"subscribe") || - !strcasecmp(command,"psubscribe")) config.pubsub_mode = 1; + !strcasecmp(command,"psubscribe") || + !strcasecmp(command,"ssubscribe")) config.pubsub_mode = 1; if (!strcasecmp(command,"sync") || !strcasecmp(command,"psync")) config.slave_mode = 1; |