summaryrefslogtreecommitdiff
path: root/examples/redis-unstable/tests/modules/publish.c
diff options
context:
space:
mode:
Diffstat (limited to 'examples/redis-unstable/tests/modules/publish.c')
-rw-r--r--examples/redis-unstable/tests/modules/publish.c57
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;
-}