COOK-2611 Adding queues parameter to celery LWRP

Cameron Johnston · Cameron Johnston · commit ecdf3912e1af · 2013-04-09T05:50:25.000-06:00
Bind celery listeners to particular queues by providing an array
of queue names to the 'queues' parameter. Defaults to ['celery'].

This change modifies the provider to use the -Q flag with the
list of queues from this parameter at every invocation. Celery
documentation states that 'celery' is the default queue name, so
this ought not to modify behavior for those currently using this LWRP.
diff --git a/providers/celery.rb b/providers/celery.rb
@@ -61,7 +61,7 @@
   end
 
   cmds = {}
-  cmds[:celeryd] = "celeryd #{new_resource.celerycam ? "-E" : ""}" if new_resource.celeryd
+  cmds[:celeryd] = "celeryd -Q #{new_resource.queues.join(',')} #{new_resource.celerycam ? "-E" : ""}" if new_resource.celeryd
   cmds[:celerybeat] = "celerybeat" if new_resource.celerybeat
   if new_resource.celerycam
     if new_resource.django
diff --git a/resources/celery.rb b/resources/celery.rb
@@ -28,6 +28,7 @@
 attribute :celerycam, :kind_of => [TrueClass, FalseClass], :default => false
 attribute :camera_class, :kind_of => [String, NilClass], :default => nil
 attribute :environment, :kind_of => [Hash], :default => {}
+attribute :queues, :kind_of => [Array], :default => ['celery']
 
 def config_base
   config.split(/[\\\/]/).last
