lib/rocketjob.rb in rocketjob-5.4.1 vs lib/rocketjob.rb in rocketjob-6.0.0.rc1

- old
+ new

@@ -1,43 +1,54 @@ require "iostreams" require "semantic_logger" require "symmetric-encryption" require "mongoid" require "rocket_job/extensions/mongo/logging" +require "rocket_job/extensions/iostreams/path" +require "rocket_job/extensions/psych/yaml_tree" require "rocket_job/version" require "rocket_job/rocket_job" require "rocket_job/config" require "rocket_job/railtie" if defined?(Rails) # Apply patches to implement `with_collection` require "rocket_job/extensions/mongoid/clients/options" require "rocket_job/extensions/mongoid/contextual/mongo" require "rocket_job/extensions/mongoid/factory" -# Apply patches for deprecated Symbol type -require "rocket_job/extensions/mongoid/remove_warnings" +# Backport New StringifiedSymbol type in Mongoid v7.2 +require "rocket_job/extensions/mongoid/stringified_symbol" unless defined?(Mongoid::StringifiedSymbol) # @formatter:off module RocketJob - autoload :ActiveWorker, "rocket_job/active_worker" - autoload :Batch, "rocket_job/batch" - autoload :CLI, "rocket_job/cli" - autoload :DirmonEntry, "rocket_job/dirmon_entry" - autoload :Event, "rocket_job/event" - autoload :Heartbeat, "rocket_job/heartbeat" - 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" + autoload :ActiveWorker, "rocket_job/active_worker" + autoload :Batch, "rocket_job/batch" + autoload :CLI, "rocket_job/cli" + autoload :DirmonEntry, "rocket_job/dirmon_entry" + autoload :Event, "rocket_job/event" + autoload :Heartbeat, "rocket_job/heartbeat" + autoload :Job, "rocket_job/job" + autoload :JobException, "rocket_job/job_exception" + autoload :LookupCollection, "rocket_job/lookup_collection" + autoload :Worker, "rocket_job/worker" + autoload :Performance, "rocket_job/performance" + autoload :RactorWorker, "rocket_job/ractor_worker" + autoload :Server, "rocket_job/server" + autoload :Sliced, "rocket_job/sliced" + autoload :Subscriber, "rocket_job/subscriber" + autoload :Supervisor, "rocket_job/supervisor" + autoload :ThreadWorker, "rocket_job/thread_worker" + autoload :ThrottleDefinition, "rocket_job/throttle_definition" + autoload :ThrottleDefinitions, "rocket_job/throttle_definitions" + autoload :WorkerPool, "rocket_job/worker_pool" + module Category + autoload :Base, "rocket_job/category/base" + autoload :Input, "rocket_job/category/input" + autoload :Output, "rocket_job/category/output" + end + module Plugins module Job autoload :Callbacks, "rocket_job/plugins/job/callbacks" autoload :Defaults, "rocket_job/plugins/job/defaults" autoload :StateMachine, "rocket_job/plugins/job/state_machine" @@ -47,41 +58,41 @@ 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 - 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" - autoload :Singleton, "rocket_job/plugins/singleton" - autoload :StateMachine, "rocket_job/plugins/state_machine" - autoload :Transaction, "rocket_job/plugins/transaction" + 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" + autoload :Singleton, "rocket_job/plugins/singleton" + autoload :StateMachine, "rocket_job/plugins/state_machine" + autoload :Transaction, "rocket_job/plugins/transaction" end module Jobs - autoload :ActiveJob, "rocket_job/jobs/active_job" - autoload :CopyFileJob, "rocket_job/jobs/copy_file_job" - autoload :DirmonJob, "rocket_job/jobs/dirmon_job" - autoload :OnDemandBatchJob, "rocket_job/jobs/on_demand_batch_job" - autoload :OnDemandBatchTabularJob, "rocket_job/jobs/on_demand_batch_tabular_job" - autoload :OnDemandJob, "rocket_job/jobs/on_demand_job" - autoload :HousekeepingJob, "rocket_job/jobs/housekeeping_job" - autoload :PerformanceJob, "rocket_job/jobs/performance_job" - autoload :SimpleJob, "rocket_job/jobs/simple_job" - autoload :UploadFileJob, "rocket_job/jobs/upload_file_job" + autoload :ActiveJob, "rocket_job/jobs/active_job" + autoload :CopyFileJob, "rocket_job/jobs/copy_file_job" + autoload :DirmonJob, "rocket_job/jobs/dirmon_job" + autoload :OnDemandBatchJob, "rocket_job/jobs/on_demand_batch_job" + autoload :OnDemandJob, "rocket_job/jobs/on_demand_job" + autoload :HousekeepingJob, "rocket_job/jobs/housekeeping_job" + autoload :PerformanceJob, "rocket_job/jobs/performance_job" + autoload :SimpleJob, "rocket_job/jobs/simple_job" + autoload :UploadFileJob, "rocket_job/jobs/upload_file_job" + module ReEncrypt if defined?(ActiveRecord) && defined?(SyncAttr) - autoload :RelationalJob, "rocket_job/jobs/re_encrypt/relational_job" + autoload :RelationalJob, "rocket_job/jobs/re_encrypt/relational_job" end end end module Subscribers - autoload :Logger, "rocket_job/subscribers/logger" - autoload :Server, "rocket_job/subscribers/server" - autoload :Worker, "rocket_job/subscribers/worker" + autoload :Logger, "rocket_job/subscribers/logger" + autoload :Server, "rocket_job/subscribers/server" + autoload :Worker, "rocket_job/subscribers/worker" end end # Add Active Job adapter for Rails require "rocket_job/extensions/rocket_job_adapter" if defined?(ActiveJob)