require 'rubygems'
require 'eventmachine'

$ch = EM::Channel.new

Thread.new do
    $ch.subscribe do |msg|
        puts "Got #{msg}"
    end

    EM.run
end

loop do
    $ch.push(:kikoo)
    sleep 1
end