diff --git a/lib/distributed_cache.rb b/lib/distributed_cache.rb index 28307e37512..777c9b780ea 100644 --- a/lib/distributed_cache.rb +++ b/lib/distributed_cache.rb @@ -26,6 +26,7 @@ class DistributedCache next if payload["origin"] == current.identity next if current.key != payload["hash_key"] + next if payload["discourse_version"] != Discourse.git_version hash = current.hash(message.site_id) @@ -63,6 +64,7 @@ class DistributedCache def self.publish(hash, message) message[:origin] = hash.identity message[:hash_key] = hash.key + message[:discourse_version] = Discourse.git_version MessageBus.publish(channel_name, message, { user_ids: [-1] }) end