Class: Qs::QsClient

Inherits:
Object
  • Object
show all
Includes:
Client
Defined in:
lib/qs/client.rb

Instance Method Summary collapse

Methods included from Client

included, new

Constructor Details

#initialize(*args) ⇒ QsClient

Returns a new instance of QsClient.



120
121
122
123
 
# File 'lib/qs/client.rb', line 120

def initialize(*args)
  super
  @redis = HellaRedis::Connection.new(self.redis_connect_hash)
end

Instance Method Details

#push(queue_name, payload_hash) ⇒ Object 



125
126
127
128
129
 
# 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