diff options
Diffstat (limited to 'examples/redis-unstable/tests/modules/publish.c')
| -rw-r--r-- | examples/redis-unstable/tests/modules/publish.c | 57 |
1 files changed, 0 insertions, 57 deletions
diff --git a/examples/redis-unstable/tests/modules/publish.c b/examples/redis-unstable/tests/modules/publish.c deleted file mode 100644 index ff276d8..0000000 --- a/examples/redis-unstable/tests/modules/publish.c +++ /dev/null @@ -1,57 +0,0 @@ -#include "redismodule.h" -#include <string.h> -#include <assert.h> -#include <unistd.h> - -#define UNUSED(V) ((void) V) - -int cmd_publish_classic_multi(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) -{ - if (argc < 3) - return RedisModule_WrongArity(ctx); - RedisModule_ReplyWithArray(ctx, argc-2); - for (int i = 2; i < argc; i++) { - int receivers = RedisModule_PublishMessage(ctx, argv[1], argv[i]); - RedisModule_ReplyWithLongLong(ctx, receivers); - } - return REDISMODULE_OK; -} - -int cmd_publish_classic(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) -{ - if (argc != 3) - return RedisModule_WrongArity(ctx); - - int receivers = RedisModule_PublishMessage(ctx, argv[1], argv[2]); - RedisModule_ReplyWithLongLong(ctx, receivers); - return REDISMODULE_OK; -} - -int cmd_publish_shard(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) -{ - if (argc != 3) - return RedisModule_WrongArity(ctx); - - int receivers = RedisModule_PublishMessageShard(ctx, argv[1], argv[2]); - RedisModule_ReplyWithLongLong(ctx, receivers); - return REDISMODULE_OK; -} - -int RedisModule_OnLoad(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) { - UNUSED(argv); - UNUSED(argc); - - if (RedisModule_Init(ctx,"publish",1,REDISMODULE_APIVER_1)== REDISMODULE_ERR) - return REDISMODULE_ERR; - - if (RedisModule_CreateCommand(ctx,"publish.classic",cmd_publish_classic,"",0,0,0) == REDISMODULE_ERR) - return REDISMODULE_ERR; - - if (RedisModule_CreateCommand(ctx,"publish.classic_multi",cmd_publish_classic_multi,"",0,0,0) == REDISMODULE_ERR) - return REDISMODULE_ERR; - - if (RedisModule_CreateCommand(ctx,"publish.shard",cmd_publish_shard,"",0,0,0) == REDISMODULE_ERR) - return REDISMODULE_ERR; - - return REDISMODULE_OK; -} |
