class RedisAlerting::FayePublisher
Public Class Methods
new(url)
click to toggle source
# File lib/redis_alerting/faye_publisher.rb, line 8 def initialize(url) Thread.new { EventMachine.run } unless EventMachine.reactor_running? && EventMachine.reactor_thread.alive? @client = Faye::Client.new(url) end
Public Instance Methods
publish(channel, message)
click to toggle source
# File lib/redis_alerting/faye_publisher.rb, line 13 def publish(channel, message) channel = "/#{channel}" unless channel.start_with?("/") @client.publish(channel, message) end