Added ability for enqueue hook to modify the job object before being …

…saved.

lib/delayed/backend/base.rb

@@ -25,8 +25,9 @@ def enqueue(*args)
           end
 
           if Delayed::Worker.delay_jobs
-            self.create(options).tap do |job|
+            self.new(options).tap do |job|
               job.hook(:enqueue)
+              job.save
             end
           else
             Delayed::Job.new(:payload_object => options[:payload_object]).tap do |job|

spec/active_record_job_spec.rb

@@ -33,4 +33,12 @@
       Delayed::Backend::ActiveRecord::Job.after_fork
     end
   end
+
+  describe "enqueue" do
+    it "should allow enqueue hook to modify job at DB level" do
+      later = described_class.db_time_now + 20.minutes
+      job = described_class.enqueue :payload_object => EnqueueJobMod.new
+      Delayed::Backend::ActiveRecord::Job.find(job.id).run_at.should be_within(1).of(later)
+    end
+  end
 end

spec/sample_jobs.rb

@@ -67,3 +67,9 @@ def failure(job)
     self.class.messages << 'failure'
   end
 end
+
+class EnqueueJobMod < SimpleJob
+  def enqueue(job)
+    job.run_at = 20.minutes.from_now
+  end
+end