From 17d843a0adcff28e71e94012aaabadd9ff18c2f1 Mon Sep 17 00:00:00 2001 From: Sam Date: Fri, 22 May 2015 11:20:41 +1000 Subject: [PATCH] FIX: upgrade resilient distributed cache only load messages in distributed cache if discourse version matches --- lib/distributed_cache.rb | 2 ++ 1 file changed, 2 insertions(+) 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