module HornetQ::Server

  class Factory
    def self.create_server(parms={})
      HornetQ::Server.load_requirements

      if parms.kind_of?(String)
        uri = HornetQ::URI.new(parms)
        parms = uri.params
      else
        raise "Missing :uri param in HornetQ::Server.create_server" unless parms[:uri]
        uri = HornetQ::URI.new(parms.delete(:uri))
        # parms override uri params
        parms = uri.params.merge(parms)
      end
      config = Java::org.hornetq.core.config.impl.ConfigurationImpl.new
      data_directory = parms.delete(:data_directory) || HornetQ::DEFAULT_DATA_DIRECTORY
      config.paging_directory = "#{data_directory}/paging"
      config.bindings_directory = "#{data_directory}/bindings"
      config.journal_directory = "#{data_directory}/journal"
      config.large_messages_directory = "#{data_directory}/large-messages"

      if uri.host == 'invm'
        acceptor = Java::org.hornetq.api.core.TransportConfiguration.new(HornetQ::INVM_ACCEPTOR_CLASS_NAME)
        config.persistence_enabled = false
        config.security_enabled    = false
      else
        acceptor = Java::org.hornetq.api.core.TransportConfiguration.new(HornetQ::NETTY_ACCEPTOR_CLASS_NAME, {'host' => uri.host, 'port' => uri.port })
        connector = Java::org.hornetq.api.core.TransportConfiguration.new(HornetQ::NETTY_CONNECTOR_CLASS_NAME, {'host' => uri.host, 'port' => uri.port })
        connector_conf_map = java.util.HashMap.new
        connector_conf_map.put('netty-connector', connector)
        config.connector_configurations = connector_conf_map
      end
      acceptor_conf_set = java.util.HashSet.new
      acceptor_conf_set.add(acceptor)
      config.acceptor_configurations = acceptor_conf_set

      if Java::org.hornetq.core.journal.impl.AIOSequentialFileFactory.isSupported
        config.journal_type = Java::org.hornetq.core.server.JournalType::ASYNCIO
      else
        puts("AIO wasn't located on this platform, it will fall back to using pure Java NIO. If your platform is Linux, install LibAIO to enable the AIO journal");
        config.journal_type = Java::org.hornetq.core.server.JournalType::NIO
      end

      if parms[:backup]
        puts "backup"
        config.backup = true
        config.shared_store = false
      elsif uri.backup_host
        puts "live"
        #backup_params.put('reconnectAttempts', -1)
        backup_connector = Java::org.hornetq.api.core.TransportConfiguration.new(HornetQ::NETTY_CONNECTOR_CLASS_NAME, {'host' => uri.backup_host, 'port' => uri.backup_port })
        connector_conf_map.put('backup-connector', backup_connector)
        config.backup_connector_name = 'backup-connector'
      elsif uri.host == 'invm'
        puts 'invm'
      else
        puts 'standalone'
      end

      parms.each_pair do |key, val|
        method = key.to_s+'='
        if config.respond_to? method
          config.send method, val
          #puts "Debug: #{key} = #{config.send key}" if config.respond_to? key.to_sym
        else
          puts "Warning: Option:#{key} class=#{key.class} with value:#{val} is invalid and being ignored"
        end
      end

      return Java::org.hornetq.core.server.HornetQServers.newHornetQServer(config)
    end
    
    # Start a new server instance and stop it once the supplied block completes
    def self.start(params={}, &block)
      server = nil
      begin
        server = self.create_server(params)
        server.start
        block.call(server)
      ensure
        server.stop if server
      end
    end
    
  end
end