require 'adaptation'

environment = "development" # TODO: "un-hardcode" this
config = YAML::load(File.open("config/mom.yml"))["development"]

case config["mom"]["type"]
  when "druby"
    require 'adaptation/druby_subscriber'

    mom_uri = "druby://#{config["mom"]["host"]}:#{config["mom"]["port"]}"
    subscriber_uri = "druby://#{config["subscriber"]["host"]}:#{config["subscriber"]["port"]}"
    topics = config["subscriber"]["topics"].split(' ')
    
    Signal.trap("INT") { puts "Shutting down subscriber (#{config["mom"]["type"]})"; exit }

    oapdaemon = Adaptation::Mom::DrubySubscriber.new subscriber_uri, mom_uri, topics
    oapdaemon.start

  #when "xmlblaster"
    #

  else
    puts "Unknown MOM server type: #{config["mom"]["type"]}"
end