Sha256: af6e33e6342462177a62caa3d873ef4c44decadc65346bfde832309827b09ad1

Contents?: true

Size: 428 Bytes

Versions: 25

Compression:

Stored size: 428 Bytes

Contents

module Rhoconnect
  class SourceJob
    class << self
      attr_accessor :queue
    end
    
    def self.perform(job_type,source_id,app_id,user_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
      end    
    end
  end
end

Version data entries

25 entries across 25 versions & 1 rubygems

Version Path
rhoconnect-3.4.5 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.4.4 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.4.3 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.4.2 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.6 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.5 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.4 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.3 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.2 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.1 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.1.beta4 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.1.beta3 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.3.1.beta2 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.1 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.0 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.0.beta5 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.0.beta4 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.0.beta3 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.0.beta2 lib/rhoconnect/jobs/source_job.rb
rhoconnect-3.2.0.beta1 lib/rhoconnect/jobs/source_job.rb