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