exchangebroker.java

source code of voyager yellow page

/*
 * RECURSION PROPRIETARY-NOT TO BE DISCLOSED OUTSIDE RECURSION, INC.
 */

/**
 * Created by twheeler on Mar 8, 2007 at 5:29:27 PM
 */
package examples.yellowpages;

import java.util.HashMap;
import java.util.Map;

import com.recursionsw.ve.Namespace;
import com.recursionsw.ve.NamespaceException;
import com.recursionsw.ve.StartupException;
import com.recursionsw.ve.Voyager;

/**
 * 
 *
 * @author twheeler
 */
public class ExchangeBroker implements IExchangeBroker
{
  private Map exchanges = new HashMap();  
  
  public ExchangeBroker()
  {
    IStockExchange exchange = new NASDAQExchange();
    exchanges.put(exchange.getName(), exchange);
    exchange = new NYSEExchange();
    exchanges.put(exchange.getName(), exchange);
  }
  
  public IStockExchange getExchange(String name)
  {
    return (IStockExchange) exchanges.get(name);
  }

  public String[] getExchangeNames()
  {
    String[] exchangeNames = (String[]) exchanges.keySet().toArray(new String[exchanges.size()]);
    return exchangeNames;
  }
  
  public static void main(String[] args)
  {
    String serverUrl = "8000";
    if(args.length > 0)
      serverUrl = args[0];

    try
    {
      Voyager.startup(serverUrl);
      Namespace.bind("/ExchangeBroker", new ExchangeBroker());
    }
    catch (StartupException e)
    {
      System.out.println("Exception starting Voyager Edge: " + e.getMessage());
      System.exit(1);
    }
    catch (NamespaceException e)
    {
      System.out.println("Exception binding Exchange Broker: " + e.getMessage());
      System.exit(1);
    }
    
    System.out.println("Exchange Broker started on " + serverUrl);
  }

}