class SXS::Publishers::Redis

Public Class Methods

new(queue_url) click to toggle source
# File lib/sxs/publishers/redis.rb, line 8
def initialize(queue_url)
  @queue_url = queue_url
end

Public Instance Methods

publish(body) click to toggle source
# File lib/sxs/publishers/redis.rb, line 12
def publish(body)
  redis.rpush @queue_url, body
end

Private Instance Methods

redis() click to toggle source
# File lib/sxs/publishers/redis.rb, line 18
def redis
  @redis ||= ::Redis.new(::SXS.config.redis_config)
end