Add ability to configure a worker_queue

This works by overriding the `perform_async` method. I was surprised this works, but it does.

Author: jclusso

lib/fabric.rb

@@ -94,9 +94,10 @@
 require 'fabric/webhooks/subscription_deleted'
 require 'fabric/webhooks/review_opened'
 require 'fabric/webhooks/review_closed'
-require 'fabric/app/workers/worker.rb'
-require 'fabric/app/workers/webhook_worker.rb'
-require 'fabric/app/models/fabric/base.rb'
+require 'fabric/app/workers/base_worker'
+require 'fabric/app/workers/worker'
+require 'fabric/app/workers/webhook_worker'
+require 'fabric/app/models/fabric/base'
 
 module Fabric
   autoload :BalanceTransaction, 'fabric/app/models/fabric/balance_transaction'
@@ -146,6 +147,7 @@ class Config
     attr_accessor :worker_callback
     attr_accessor :persist_models
     attr_accessor :currencies
+    attr_accessor :worker_queue
 
     def initialize
       @store_events = true
@@ -154,6 +156,7 @@ def initialize
       @worker_callback = Proc.new {}
       @persist_models = :all
       @currencies = %w(usd)
+      @worker_queue = 'fabric'
     end
 
     def persist?(document)

lib/fabric/app/workers/base_worker.rb

@@ -0,0 +1,19 @@
+module Fabric
+  class BaseWorker
+    include Fabric
+    include Sidekiq::Worker
+
+    def self.perform_async(...)
+      set(queue: Fabric.config.worker_queue).perform_async(...)
+    end
+
+    def self.perform_in(interval, ...)
+      set(queue: Fabric.config.worker_queue).perform_in(interval, ...)
+    end
+
+    def self.perform_at(timestamp, ...)
+      set(queue: Fabric.config.worker_queue).perform_at(timestamp, ...)
+    end
+
+  end
+end

lib/fabric/app/workers/webhook_worker.rb

@@ -1,13 +1,11 @@
 module Fabric
-  class WebhookWorker
-    include Sidekiq::Worker
-
-    sidekiq_options queue: 'fabric'
+  class WebhookWorker < BaseWorker
 
     def perform(event, webhook_class)
       log_data = { event: event['id'], webhook_class: webhook_class }
       Fabric.config.logger.info("started #{log_data.to_json}")
       "Fabric::Webhooks::#{webhook_class.camelcase}".constantize.new.call(event)
     end
+
   end
 end

lib/fabric/app/workers/worker.rb

@@ -1,9 +1,7 @@
 module Fabric
-  class Worker
-    include Fabric
-    include Sidekiq::Worker
+  class Worker < BaseWorker
 
-    sidekiq_options queue: 'fabric', retry: false
+    sidekiq_options retry: false
 
     def perform(operation, *args)
       @log_data = { class: self.class.name, operation: operation, args: args }