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