gistfile1.rb

require 'json'
require 'eventmachine'
require 'sinatra/async'

class Main
  register Sinatra::Async

  def self.handleMessage(channel, message)
    puts "Handling message for channel #{channel}: #{message}"
  end
  
  configure do
    REDISPUBSUB = Redis.new(monk_settings(:redis))
    PUBSUBTHREAD = Thread.new(self) { |main|
    	REDISPUBSUB.psubscribe("channel.*") do |on|
      on.psubscribe do |event, total|
        puts "Subscribed to #{event} (#{total} subscriptions)"
      end
      
      on.pmessage do |pattern, channel, message|
        puts "Fielding message: #{message}"
        puts "#{main.method(:handleMessage)}"
        main.handleMessage(channel, message)
      end
    end
    }
  end

end