lib/taskinator/queues.rb in taskinator-0.3.3 vs lib/taskinator/queues.rb in taskinator-0.3.5

@@ -2,12 +2,11 @@
   module Queues
 
     DefaultConfig = {
       :definition_queue => :default,
       :process_queue => :default,
-      :task_queue => :default,
-      :job_queue => :default,
+      :task_queue => :default
     }.freeze
 
     def self.create_adapter(adapter, config={})
       begin
         LoggedAdapter.new(send("create_#{adapter}_adapter", config))
@@ -30,9 +29,14 @@
       end
 
       def enqueue_create_process(definition, uuid, args)
         Taskinator.logger.info("Enqueuing process creation for #{definition}")
         adapter.enqueue_create_process(definition, uuid, args)
+      end
+
+      def enqueue_process(process)
+        Taskinator.logger.info("Enqueuing process #{process}")
+        adapter.enqueue_process(process)
       end
 
       def enqueue_task(task)
         Taskinator.logger.info("Enqueuing task #{task}")
         adapter.enqueue_task(task)