rocketjob.rb in rocketjob-4.1.0

- old
+ new

@@ -21,16 +21,20 @@
   autoload :ActiveWorker,       'rocket_job/active_worker'
   autoload :Batch,              'rocket_job/batch'
   autoload :CLI,                'rocket_job/cli'
   autoload :Config,             'rocket_job/config'
   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 :Subscriber,         'rocket_job/subscriber'
+  autoload :Supervisor,         'rocket_job/supervisor'
+  autoload :WorkerPool,         'rocket_job/worker_pool'
 
   module Plugins
     module Job
       autoload :Callbacks,           'rocket_job/plugins/job/callbacks'
       autoload :Defaults,            'rocket_job/plugins/job/defaults'
@@ -67,19 +71,25 @@
     autoload :SimpleJob,        'rocket_job/jobs/simple_job'
     autoload :UploadFileJob,    'rocket_job/jobs/upload_file_job'
   end
 
   module Sliced
-    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'
+    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'
+      autoload :Input,          'rocket_job/sliced/writer/input'
+      autoload :Output,         'rocket_job/sliced/writer/output'
     end
+  end
+
+  module Subscribers
+    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)