class Hivent::Redis::Signal
Constants
- MAX_TRIES
- SLEEP
Public Class Methods
new(*args)
click to toggle source
Calls superclass method
Hivent::AbstractSignal::new
# File lib/hivent/redis/signal.rb, line 14 def initialize(*args) super @producer = Producer.new(redis) end
Private Instance Methods
redis()
click to toggle source
# File lib/hivent/redis/signal.rb, line 28 def redis Hivent::Redis.redis end
send_message(message, key, _version)
click to toggle source
# File lib/hivent/redis/signal.rb, line 22 def send_message(message, key, _version) Retryable.retryable(tries: MAX_TRIES, sleep: SLEEP) do producer.write(name, message.to_json, key) end end