class Shower::Stream
Public Class Methods
publish(event, message)
click to toggle source
Publish a message to the gemgento_message stream
@param [String] event @param [Hash] Message
# File lib/shower/stream.rb, line 8 def self.publish(event, message) $redis.publish(event, message.to_json) end
subscribe(events) { |event, data| ... }
click to toggle source
Yield event and data back to subscribed entity
@param [Array] events
# 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