Contents

require "kyew/version"

require 'json'
require 'redis'

class Kyew
  DEFAULT_REDIS_URL = 'redis://localhost:6379/1'

  def initialize(redis_or_url = DEFAULT_REDIS_URL)
    @redis = if redis_or_url.respond_to?(:lpush)
      redis_or_url
    else
      Redis.new(url: redis_or_url)
    end
  end

  def pop_message(queue_name)
    JSON.parse(redis.lpop(queue_name))
  end

  def push_message(queue_name, message)
    redis.lpush(queue_name, message.to_json)
  end

  private

  attr_reader :redis
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
kyew-0.1.0	lib/kyew.rb