github-mirror/discourse
2
0
Fork 0
mirror of https://github.com/discourse/discourse.git synced 2025-05-24 00:41:16 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

FIX: upgrade resilient distributed cache

Browse Source 
only load messages in distributed cache if discourse version matches
This commit is contained in:
Sam
2015-05-22 11:20:41 +10:00
parent df5be88a77
commit 17d843a0ad
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
lib/distributed_cache.rb
View File

@ -26,6 +26,7 @@ class DistributedCache
next if payload["origin"] == current.identity next if payload["origin"] == current.identity
next if current.key != payload["hash_key"] next if current.key != payload["hash_key"]
next if payload["discourse_version"] != Discourse.git_version
hash = current.hash(message.site_id) hash = current.hash(message.site_id)
@ -63,6 +64,7 @@ class DistributedCache
def self.publish(hash, message) def self.publish(hash, message)
message[:origin] = hash.identity message[:origin] = hash.identity
message[:hash_key] = hash.key message[:hash_key] = hash.key
message[:discourse_version] = Discourse.git_version
MessageBus.publish(channel_name, message, { user_ids: [-1] }) MessageBus.publish(channel_name, message, { user_ids: [-1] })
end end