Contents

require 'socket'

module Whistle
  class Relay
    def self.activate
      Thread.new do
        server = TCPServer.new($config.relay.host, $config.relay.port)
        puts "Started relay on port #{$config.relay.port}"
        while s = server.accept
          begin
            msg = s.gets
            puts "Received #{msg}, relaying"
            msg.chomp!.strip! unless msg.blank?
            $switchbox.deliver(msg) unless msg.blank?
          rescue => e
            puts "ERROR: #{e.message}"
          ensure
            s.close
          end
        end
      end #.abort_on_exception = true
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
whistle-0.1.1	lib/relay.rb
whistle-0.1	lib/relay.rb