Contents

# frozen_string_literal: true

require 'json'
require 'uri'

module Quiq
  class Client
    def push(job)
      serialized = JSON.dump(job.serialize)
      Async do
        Quiq.redis.lpush("queue:#{job.queue_name}", serialized)
      end
    end

    def self.push(job)
      new.push(job)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
quiq-0.1.0	lib/quiq/client.rb