diff --git a/src/cluster_legacy.c b/src/cluster_legacy.c index 43fcc84a73..bcde3b68dd 100644 --- a/src/cluster_legacy.c +++ b/src/cluster_legacy.c @@ -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); }