Sha256: 28bcd567863b3f491b13e532908bf2ef5e36ecc274e9c4945e7a769fabec8185
Contents?: true
Size: 446 Bytes
Versions: 49
Compression:
Stored size: 446 Bytes
Contents
module Rhosync
class SourceJob
class << self
attr_accessor :queue
end
def self.perform(job_type,source_id,app_id,user_id,client_id,params)
source = Source.load(source_id,{:app_id => app_id,:user_id => user_id})
source_sync = SourceSync.new(source)
case job_type.to_sym
when :query then source_sync.do_query(params)
when :cud then source_sync.do_cud(client_id)
end
end
end
end
Version data entries
49 entries across 49 versions & 1 rubygems