class Asynchronic::QueueEngine::Synchronic::Queue

Attributes

engine[R]

Public Class Methods

new(engine) click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 43
def initialize(engine)
  @engine = engine
end

Public Instance Methods

push(message) click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 47
def push(message)
  process = engine.environment.load_process(message)

  if engine.stubs[process.type]
    job = process.job
    block = engine.stubs[process.type]
    process.define_singleton_method :job do
      MockJob.new job, process, &block
    end
  end

  process.execute
end