Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorKamil Trzcinski <ayufan@ayufan.eu>2017-03-06 13:44:45 +0300
committerKamil Trzcinski <ayufan@ayufan.eu>2017-03-06 13:44:45 +0300
commit2d652fcf5a1c801c11ce11414f21234d409315f4 (patch)
tree90b291705a5f54fe0e75e1f983e1377d993a7243 /lib
parent3f5191de6db80872e3e712247b5582bdc4eec296 (diff)
Update notification code
Diffstat (limited to 'lib')
-rw-r--r--lib/gitlab/workhorse.rb5
1 files changed, 2 insertions, 3 deletions
diff --git a/lib/gitlab/workhorse.rb b/lib/gitlab/workhorse.rb
index 34fbb227f7b..eae1a0abf06 100644
--- a/lib/gitlab/workhorse.rb
+++ b/lib/gitlab/workhorse.rb
@@ -155,12 +155,11 @@ module Gitlab
Rails.root.join('.gitlab_workhorse_secret')
end
- def ensure_and_notify(key, value, expire: nil, overwrite: true)
+ def set_key_and_notify(key, value, expire: nil, overwrite: true)
Gitlab::Redis.with do |redis|
result = redis.set(key, value, ex: expire, nx: !overwrite)
if result
- payload = "#{key}=#{value}"
- redis.publish(NOTIFICATION_CHANNEL, payload)
+ redis.publish(NOTIFICATION_CHANNEL, "#{key}=#{value}")
value
else
redis.get(key)