# File lib/dynflow/connectors/direct.rb, line 49 def initialize(world = nil) @core = Core.spawn('connector-direct-core', self) start_listening(world) if world end
# File lib/dynflow/connectors/direct.rb, line 66 def send(envelope) @core.ask([:handle_envelope, envelope]) end
# File lib/dynflow/connectors/direct.rb, line 54 def start_listening(world) @core.ask([:start_listening, world]) end
# File lib/dynflow/connectors/direct.rb, line 62 def stop_listening(world) @core.ask([:stop_listening, world]).wait end
# File lib/dynflow/connectors/direct.rb, line 58 def stop_receiving_new_work(world) @core.ask([:stop_receiving_new_work, world]).wait end