Contents

module Taskinator
  module Queues

    # https://guides.rubyonrails.org/active_job_basics.html

    def self.create_active_job_adapter(config={})
      ActiveJobAdapter.new(config)
    end

    class ActiveJobAdapter
      def initialize(config={})
        @config = Taskinator::Queues::DefaultConfig.merge(config)
      end

      def enqueue_create_process(definition, uuid, args)
        queue = definition.queue || @config[:definition_queue]
        CreateProcessWorker.set(:queue => queue)
          .perform_later(definition.name, uuid, Taskinator::Persistence.serialize(args))
      end

      def enqueue_process(process)
        queue = process.queue || @config[:process_queue]
        ProcessWorker.set(:queue => queue)
          .perform_later(process.uuid)
      end

      def enqueue_task(task)
        queue = task.queue || @config[:task_queue]
        TaskWorker.set(:queue => queue)
          .perform_later(task.uuid)
      end

      class CreateProcessWorker < ApplicationJob
        def perform(definition_name, uuid, args)
          Taskinator::CreateProcessWorker.new(definition_name, uuid, args).perform
        end
      end

      class ProcessWorker < ApplicationJob
        def perform(process_uuid)
          Taskinator::ProcessWorker.new(process_uuid).perform
        end
      end

      class TaskWorker < ApplicationJob
        def perform(task_uuid)
          Taskinator::TaskWorker.new(task_uuid).perform
        end
      end

    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
taskinator-0.4.7	lib/taskinator/queues/active_job.rb
taskinator-0.4.6	lib/taskinator/queues/active_job.rb
taskinator-0.4.5	lib/taskinator/queues/active_job.rb
taskinator-0.4.4	lib/taskinator/queues/active_job.rb