Skip to content

Commit

Permalink
Minor change
Browse files Browse the repository at this point in the history
Signed-off-by: Roshan Khatri <rvkhatri@amazon.com>
  • Loading branch information
roshkhatri committed Jul 22, 2024
1 parent f9bd8ff commit 64ba736
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/cluster_legacy.c
Original file line number Diff line number Diff line change
Expand Up @@ -4142,8 +4142,7 @@ void clusterPropagatePublish(robj *channel, robj *message, int sharded) {
clusterSendMessage(node->link, msgblock_light);
} else {
if (msgblock == NULL) {
msgblock = clusterCreatePublishMsgBlock(
channel, message, 0, sharded ? CLUSTERMSG_TYPE_PUBLISHSHARD : CLUSTERMSG_TYPE_PUBLISH);
msgblock = clusterCreatePublishMsgBlock(channel, message, 0, sharded);
}
clusterSendMessage(node->link, msgblock);
}
Expand Down

0 comments on commit 64ba736

Please sign in to comment.