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.



69
70
71
72
# File 'lib/qs/client.rb', line 69

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

Instance Method Details

#push(queue_name, payload) ⇒ Object



74
75
76
77
78
# File 'lib/qs/client.rb', line 74

def push(queue_name, payload)
  queue_redis_key    = Queue::RedisKey.new(queue_name)
  serialized_payload = Qs.serialize(payload)
  self.append(queue_redis_key, serialized_payload)
end