Publish a message to subscribers (see PUBLISH command). */
| 2016 | |
| 2017 | /* Publish a message to subscribers (see PUBLISH command). */ |
| 2018 | int RM_PublishMessage(RedisModuleCtx *ctx, RedisModuleString *channel, RedisModuleString *message) { |
| 2019 | UNUSED(ctx); |
| 2020 | int receivers = pubsubPublishMessage(channel, message); |
| 2021 | if (server.cluster_enabled) |
| 2022 | clusterPropagatePublish(channel, message); |
| 2023 | return receivers; |
| 2024 | } |
| 2025 | |
| 2026 | /* Return the currently selected DB. */ |
| 2027 | int RM_GetSelectedDb(RedisModuleCtx *ctx) { |
nothing calls this directly
no test coverage detected