lib/backgrounder/orm/base.rb in carrierwave_backgrounder-0.0.5 vs lib/backgrounder/orm/base.rb in carrierwave_backgrounder-0.0.6
- old
+ new
@@ -48,11 +48,19 @@
def set_#{column}_processing
self.#{column}_processing = true if respond_to?(:#{column}_processing)
end
def enqueue_#{column}_background_job
- ::Delayed::Job.enqueue #{worker}.new(self.class, id, #{column}.mounted_as)
+ if defined? ::GirlFriday
+ CARRIERWAVE_QUEUE << { :worker => #{worker}.new(self.class.name, id, #{column}.mounted_as) }
+ elsif defined? ::Delayed::Job
+ ::Delayed::Job.enqueue #{worker}.new(self.class.name, id, #{column}.mounted_as)
+ elsif defined? ::Resque
+ ::Resque.enqueue #{worker}, self.class.name, id, #{column}.mounted_as
+ elsif defined? ::Qu
+ ::Qu.enqueue #{worker}, self.class.name, id, #{column}.mounted_as
+ end
end
def trigger_#{column}_background_processing?
process_#{column}_upload != true
end
@@ -96,10 +104,18 @@
def store_#{column}!
super() if process_#{column}_upload
end
def enqueue_#{column}_background_job
- ::Delayed::Job.enqueue #{worker}.new(self.class, id, #{column}.mounted_as)
+ if defined? ::GirlFriday
+ CARRIERWAVE_QUEUE << { :worker => #{worker}.new(self.class.name, id, #{column}.mounted_as) }
+ elsif defined? ::Delayed::Job
+ ::Delayed::Job.enqueue #{worker}.new(self.class.name, id, #{column}.mounted_as)
+ elsif defined? ::Resque
+ ::Resque.enqueue #{worker}, self.class.name, id, #{column}.mounted_as
+ elsif defined? ::Qu
+ ::Qu.enqueue #{worker}, self.class.name, id, #{column}.mounted_as
+ end
end
def trigger_#{column}_background_storage?
process_#{column}_upload != true
end