Class: Shower::Stream

Inherits:
Object
  • Object
show all
Defined in:
lib/shower/stream.rb

Class Method Summary collapse

Class Method Details

.publish(event, message) ⇒ Object

Publish a message to the gemgento_message stream

Parameters:

  • event (String)
  • Message (Hash) 


8
9
10
 
# File 'lib/shower/stream.rb', line 8

def self.publish(event, message)
  $redis.publish(event, message.to_json)
end

.subscribe(events) ⇒ Object

Yield event and data back to subscribed entity

Parameters:

  • events (Array) 


15
16
17
18
19
20
21
 
# File 'lib/shower/stream.rb', line 15

def self.subscribe(events)
  $redis.subscribe(events << 'heartbeat') do |on|
    on.message do |event, data|
      yield(event, data)
    end
  end
end