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