Publish a message to subscribers (see PUBLISH command). */
| 2095 | |
| 2096 | /* Publish a message to subscribers (see PUBLISH command). */ |
| 2097 | int RM_PublishMessage(RedisModuleCtx *ctx, RedisModuleString *channel, RedisModuleString *message) { |
| 2098 | UNUSED(ctx); |
| 2099 | int receivers = pubsubPublishMessage(channel, message); |
| 2100 | if (g_pserver->cluster_enabled) |
| 2101 | clusterPropagatePublish(channel, message); |
| 2102 | return receivers; |
| 2103 | } |
| 2104 | |
| 2105 | /* Return the currently selected DB. */ |
| 2106 | int RM_GetSelectedDb(RedisModuleCtx *ctx) { |
nothing calls this directly
no test coverage detected