don't auto start litejob in Rails unless the adapter is intiaialized, fixes #126

Author: oldmoe

lib/active_job/queue_adapters/litejob_adapter.rb

@@ -13,16 +13,15 @@ module QueueAdapters
     #
     #
     #   Rails.application.config.active_job.queue_adapter = :litejob
+
     class LitejobAdapter
-      def initialize(options = {})
-        # we currently don't honour individual options per job class
-        # possible in the future?
-        # Job.options = DEFAULT_OPTIONS.merge(options)
-      end
 
-      def enqueue_after_transaction_commit?
-        Job.options[:enqueue_after_transaction_commit]
-      end
+      # we currently don't honour individual options per job class
+      # possible in the future?
+      # Job.options = DEFAULT_OPTIONS.merge(options)
+      def initialize(options = {}) = Job.get_jobqueue
+
+      def enqueue_after_transaction_commit? = Job.options[:enqueue_after_transaction_commit]
 
       def enqueue(job) # :nodoc:
         Job.queue = job.queue_name
@@ -36,17 +35,18 @@ def enqueue_at(job, time) # :nodoc:
       end
 
       class Job # :nodoc:
+
         DEFAULT_OPTIONS = {
           config_path: "./config/litejob.yml",
           logger: nil, # Rails performs its logging already
           enqueue_after_transaction_commit: true
         }
-
+        # ensure litejob is not started unless the LitejobAdapter is initialized
+        def self.defer_litejob_start? = true
         include ::Litejob
 
-        def perform(job_data)
-          Base.execute job_data
-        end
+        def perform(job_data) = Base.execute job_data
+
       end
     end
   end

lib/litestack.rb

@@ -4,6 +4,8 @@
 require_relative "litestack/version"
 require_relative "litestack/litescheduler"
 require_relative "litestack/litesupport"
+
+# auto load each of thease when/if needed
 require_relative "litestack/litemetric"
 require_relative "litestack/litedb"
 require_relative "litestack/litecache"

lib/litestack/litejob.rb

@@ -41,40 +41,30 @@
 module Litejob
   def self.included(klass)
     klass.extend(ClassMethods)
-    klass.get_jobqueue
+    klass.get_jobqueue unless klass.defer_litejob_start?
   end
 
   module ClassMethods
-    def perform_async(*params)
-      get_jobqueue.push(name, params, 0, queue)
-    end
 
-    def perform_at(time, *params)
-      delay = time.to_i - Time.now.to_i
-      get_jobqueue.push(name, params, delay, queue)
-    end
+    def perform_async(*params) = get_jobqueue.push(name, params, 0, queue)
 
-    def perform_in(delay, *params)
-      get_jobqueue.push(name, params, delay, queue)
-    end
+    def perform_at(time, *params) = get_jobqueue.push(name, params, time.to_i - Time.now.to_i, queue)
 
-    def perform_after(delay, *params)
-      perform_in(delay, *params)
-    end
+    def perform_in(delay, *params) = get_jobqueue.push(name, params, delay, queue)
 
-    def process_jobs
-      get_jobqueue
-    end
+    def perform_after(delay, *params) = perform_in(delay, *params)
 
-    def delete(id)
-      get_jobqueue.delete(id)
-    end
+    def process_jobs = get_jobqueue
 
-    def queue
-      @queue_name ||= "default"
-    end
+    def delete(id) = get_jobqueue.delete(id)
 
-    def queue=(queue_name)
+    def queue = @queue_name ||= "default"
+    
+    def get_jobqueue = Litejobqueue.jobqueue(options)
+    
+    def defer_litejob_start? = false
+    
+    def queue=(queue_name) 
       @queue_name = queue_name.to_s
     end
 
@@ -85,9 +75,6 @@ def options
         {}
       end
     end
-
-    def get_jobqueue
-      Litejobqueue.jobqueue(options)
-    end
+    
   end
 end