Class: Kyew

Inherits:
Object
  • Object
show all
Defined in:
lib/kyew.rb,
lib/kyew/version.rb

Constant Summary collapse

DEFAULT_REDIS_URL = 
'redis://localhost:6379/1'
VERSION = 
"0.1.2"

Instance Method Summary collapse

Constructor Details

#initialize(redis_or_url = DEFAULT_REDIS_URL) ⇒ Kyew

Returns a new instance of Kyew.



9
10
11
12
13
14
15
 
# File 'lib/kyew.rb', line 9

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

Instance Method Details

#pop_message(queue_name) ⇒ Object 



17
18
19
20
 
# File 'lib/kyew.rb', line 17

def pop_message(queue_name)
  raw_response = redis.rpop(queue_name)
  raw_response.nil? ? nil : JSON.parse(raw_response)
end

#push_message(queue_name, message) ⇒ Object 



22
23
24
 
# File 'lib/kyew.rb', line 22

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