class Asynchronic::Environment
Attributes
data_store[R]
notifier[R]
queue_engine[R]
Public Class Methods
new(queue_engine, data_store, notifier)
click to toggle source
# File lib/asynchronic/environment.rb, line 6 def initialize(queue_engine, data_store, notifier) @queue_engine = queue_engine @data_store = data_store @notifier = notifier end
Public Instance Methods
create_process(type, params={})
click to toggle source
# File lib/asynchronic/environment.rb, line 24 def create_process(type, params={}) Process.create self, type, params end
default_queue()
click to toggle source
# File lib/asynchronic/environment.rb, line 16 def default_queue queue queue_engine.default_queue end
enqueue(msg, queue=nil)
click to toggle source
# File lib/asynchronic/environment.rb, line 20 def enqueue(msg, queue=nil) queue(queue || queue_engine.default_queue).push msg end
load_process(id)
click to toggle source
# File lib/asynchronic/environment.rb, line 28 def load_process(id) Process.new self, id end
processes()
click to toggle source
# File lib/asynchronic/environment.rb, line 32 def processes Process.all self end
queue(name)
click to toggle source
# File lib/asynchronic/environment.rb, line 12 def queue(name) queue_engine[name] end