lib/rocketjob.rb in rocketjob-5.3.3 vs lib/rocketjob.rb in rocketjob-5.4.0.beta1
- old
+ new
@@ -27,10 +27,11 @@
autoload :Job, "rocket_job/job"
autoload :JobException, "rocket_job/job_exception"
autoload :Worker, "rocket_job/worker"
autoload :Performance, "rocket_job/performance"
autoload :Server, "rocket_job/server"
+ autoload :Sliced, "rocket_job/sliced"
autoload :Subscriber, "rocket_job/subscriber"
autoload :Supervisor, "rocket_job/supervisor"
autoload :ThrottleDefinition, "rocket_job/throttle_definition"
autoload :ThrottleDefinitions, "rocket_job/throttle_definitions"
autoload :WorkerPool, "rocket_job/worker_pool"
@@ -46,14 +47,10 @@
autoload :Throttle, "rocket_job/plugins/job/throttle"
autoload :ThrottleRunningJobs, "rocket_job/plugins/job/throttle_running_jobs"
autoload :Transaction, "rocket_job/plugins/job/transaction"
autoload :Worker, "rocket_job/plugins/job/worker"
end
- module Rufus
- autoload :CronLine, "rocket_job/plugins/rufus/cron_line"
- autoload :ZoTime, "rocket_job/plugins/rufus/zo_time"
- end
autoload :Cron, "rocket_job/plugins/cron"
autoload :Document, "rocket_job/plugins/document"
autoload :ProcessingWindow, "rocket_job/plugins/processing_window"
autoload :Restart, "rocket_job/plugins/restart"
autoload :Retry, "rocket_job/plugins/retry"
@@ -75,24 +72,9 @@
autoload :UploadFileJob, "rocket_job/jobs/upload_file_job"
module ReEncrypt
if defined?(ActiveRecord) && defined?(SyncAttr)
autoload :RelationalJob, "rocket_job/jobs/re_encrypt/relational_job"
end
- end
- end
-
- module Sliced
- autoload :CompressedSlice, "rocket_job/sliced/compressed_slice"
- autoload :EncryptedSlice, "rocket_job/sliced/encrypted_slice"
- autoload :Input, "rocket_job/sliced/input"
- autoload :Output, "rocket_job/sliced/output"
- autoload :Slice, "rocket_job/sliced/slice"
- autoload :Slices, "rocket_job/sliced/slices"
- autoload :Store, "rocket_job/sliced/store"
-
- module Writer
- autoload :Input, "rocket_job/sliced/writer/input"
- autoload :Output, "rocket_job/sliced/writer/output"
end
end
module Subscribers
autoload :Logger, "rocket_job/subscribers/logger"