Class: Workling::Remote::Invokers::EventmachineSubscriber
- Defined in:
- lib/workling/remote/invokers/eventmachine_subscriber.rb
Instance Attribute Summary
Attributes inherited from Base
Instance Method Summary collapse
-
#initialize(routing, client_class) ⇒ EventmachineSubscriber
constructor
A new instance of EventmachineSubscriber.
-
#listen ⇒ Object
Starts EM loop and sets up subscription callbacks for workers.
- #stop ⇒ Object
Methods inherited from Base
Constructor Details
#initialize(routing, client_class) ⇒ EventmachineSubscriber
Returns a new instance of EventmachineSubscriber.
12 13 14 |
# File 'lib/workling/remote/invokers/eventmachine_subscriber.rb', line 12 def initialize(routing, client_class) super end |
Instance Method Details
#listen ⇒ Object
Starts EM loop and sets up subscription callbacks for workers.
19 20 21 22 23 24 25 26 27 28 29 |
# File 'lib/workling/remote/invokers/eventmachine_subscriber.rb', line 19 def listen EM.run do connect do routes.each do |route| @client.subscribe(route) do |args| run(route, args) end end end end end |
#stop ⇒ Object
31 32 33 |
# File 'lib/workling/remote/invokers/eventmachine_subscriber.rb', line 31 def stop EM.stop if EM.reactor_running? end |