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