Merge pull request #49 from jandudulski/backburner

Add support for Backburner backend

.travis.yml

@@ -1,3 +1,5 @@
 language: ruby
 rvm:
   - 1.9.3
+services:
+  - redis-server

README.md

@@ -9,6 +9,7 @@ Supported backends:
 * Delayed::Job
 * QueueClassic
 * Torquebox
+* Backburner
 
 ## Installation
 
@@ -39,7 +40,7 @@ end
 Set your queuing backend by creating `config/initializers/devise_async.rb`:
 
 ```ruby
-# Supported options: :resque, :sidekiq, :delayed_job, :queue_classic, :torquebox
+# Supported options: :resque, :sidekiq, :delayed_job, :queue_classic, :torquebox, :backburner
 Devise::Async.backend = :resque
 ```
 

devise-async.gemspec

@@ -25,6 +25,7 @@ Gem::Specification.new do |gem|
   gem.add_development_dependency "sidekiq",                   "~> 1.2"
   gem.add_development_dependency "delayed_job_active_record", "~> 0.3"
   gem.add_development_dependency "queue_classic",             "~> 2.0"
+  gem.add_development_dependency "backburner",                "~> 0.4"
   gem.add_development_dependency "mocha",                     "~> 0.11"
   gem.add_development_dependency "minitest",                  "~> 3.0"
   gem.add_development_dependency "torquebox-no-op",           "~> 2.3"

lib/devise/async.rb

@@ -9,6 +9,7 @@ module Async
 
     module Backend
       autoload :Base,         "devise/async/backend/base"
+      autoload :Backburner,   "devise/async/backend/backburner"
       autoload :Resque,       "devise/async/backend/resque"
       autoload :Sidekiq,      "devise/async/backend/sidekiq"
       autoload :DelayedJob,   "devise/async/backend/delayed_job"

lib/devise/async/backend/backburner.rb

@@ -0,0 +1,21 @@
+module Devise
+  module Async
+    module Backend
+      class Backburner < Base
+
+        def self.enqueue(*args)
+          args.unshift(self)
+          ::Backburner.enqueue(*args)
+        end
+
+        def self.perform(*args)
+          new.perform(*args)
+        end
+
+        def self.queue
+          Devise::Async.queue
+        end
+      end
+    end
+  end
+end

test/devise/async/backend/backburner_test.rb

@@ -0,0 +1,21 @@
+require "test_helper"
+
+module Devise
+  module Async
+    module Backend
+      describe "Backburner" do
+        it "enqueues job" do
+          ::Backburner.expects(:enqueue).with(Backburner, :mailer_method, "User", 123, {})
+          Backburner.enqueue(:mailer_method, "User", 123, {})
+        end
+
+        it "delegates to devise mailer when delivering" do
+          user = create_user
+          ActionMailer::Base.deliveries = []
+          Backend::Backburner.perform(:confirmation_instructions, "User", user.id, {})
+          ActionMailer::Base.deliveries.size.must_equal 1
+        end
+      end
+    end
+  end
+end

test/devise/async/backend_test.rb

@@ -11,6 +11,10 @@ module Async
         Backend.for(:sidekiq).must_equal Backend::Sidekiq
       end
 
+      it "gives backburner as the backend" do
+        Backend.for(:backburner).must_equal Backend::Backburner
+      end
+
       it "gives delayed job as the backend" do
         Backend.for(:delayed_job).must_equal Backend::DelayedJob
       end

test/devise/async/worker_test.rb

@@ -17,6 +17,13 @@ module Async
         Worker.enqueue(:mailer_method, "User", 123, {})
       end
 
+      it "enqueues job using the backburner backend" do
+        Devise::Async.backend = :backburner
+
+        Backend::Backburner.expects(:enqueue).with(:mailer_method, "User", 123, {})
+        Worker.enqueue(:mailer_method, "User", 123, {})
+      end
+
       it "enqueues job using the delayed job backend" do
         Devise::Async.backend = :delayed_job
 

test/test_helper.rb

@@ -10,6 +10,7 @@
 require "rails/all"
 require "resque"
 require "sidekiq"
+require "backburner"
 require "delayed_job_active_record"
 require "sidekiq/testing"
 require "torquebox-no-op"