class Qs::QsClient
Public Class Methods
new(*args)
click to toggle source
Calls superclass method
Qs::Client::new
# File lib/qs/client.rb, line 120 def initialize(*args) super @redis = HellaRedis.real(self.redis_connect_hash) end
Public Instance Methods
push(queue_name, payload_hash)
click to toggle source
# File lib/qs/client.rb, line 125 def push(queue_name, payload_hash) queue_redis_key = Queue::RedisKey.new(queue_name) encoded_payload = Qs.encode(payload_hash) self.append(queue_redis_key, encoded_payload) end
Private Instance Methods
enqueue!(queue, job)
click to toggle source
# File lib/qs/client.rb, line 133 def enqueue!(queue, job) encoded_payload = Qs::Payload.serialize(job) self.append(queue.redis_key, encoded_payload) end