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