Class: Distribot::FlowFinishedHandler

Inherits:
Object
  • Object
show all
Includes:
Handler
Defined in:
lib/distribot/flow_finished_handler.rb

Instance Attribute Summary

Attributes included from Handler

#consumers, #queue_name

Instance Method Summary collapse

Methods included from Handler

handler_for, included, #initialize, queue_for

Instance Method Details

#callback(message) ⇒ Object 



7
8
9
10
11
 
# File 'lib/distribot/flow_finished_handler.rb', line 7

def callback(message)
  Distribot.redis.decr('distribot.flows.running')
  Distribot.redis.srem 'distribot.flows.active', message[:flow_id]
  Distribot.broadcast! 'distribot.flow.finished', flow_id: message[:flow_id]
end