Sha256: af8ba67edaa7aa3a91980f826fe9abe5abb76516d0e596b1b8f5a140ce43f05c

Contents?: true

Size: 449 Bytes

Versions: 10

Compression:

Stored size: 449 Bytes

Contents

module Rhoconnect
  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

10 entries across 10 versions & 1 rubygems

Version Path
rhoconnect-3.0.6 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.5 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.4 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.3 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.2 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.1 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.0 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.0.rc1 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.0.beta3 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.0.0.beta1 lib/rhoconnect/jobs/source_job.rb