sidekiq-bossman.rb in sidekiq-bossman-0.2.1

- old
+ new

@@ -4,11 +4,11 @@
   class Bossman
 
     attr_accessor :config, :pidfile,
                   :logfile, :require,
                   :timeout, :verbose, :concurrency,
-                  :queue, :environment
+                  :queue, :queues, :environment
 
 
     ##
     # Takes the following options that currently match the version
     # of Sidekiq this gem depends upon:
@@ -22,10 +22,11 @@
                          :require => "#{project_root}",
                          :environment => "development",
                          :timeout => 10,
                          :verbose => false,
                          :queue => nil,
+                         :queues => [],
                          :concurrency => nil}
       options = default_options.merge(options)
       options.each { |k, v| send("#{k}=", v) }
     end
 
@@ -36,9 +37,10 @@
       start_cmd = "nohup bundle exec sidekiq -e #{@environment} -t #{@timeout} -P #{@pidfile}"
       start_cmd << " -v" if @verbose == true
       start_cmd << " -r #{@require}" unless @require.nil?
       start_cmd << " -C #{@config}" unless @config.nil?
       start_cmd << " -q #{@queue}" unless @queue.nil?
+      @queues.each { |queue| start_cmd << " -q #{queue}" }
       start_cmd << " -c #{@concurrency}" unless @concurrency.nil?
       start_cmd << " >> #{@logfile} 2>&1 &"
       system start_cmd
     end
 