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