Client App

ClientApp.java

package com.algotree.my_project;

import java.net.URI;
import java.net.URISyntaxException;

import org.threeten.bp.Instant;

import com.opengamma.component.factory.RemoteComponentFactory;
import com.opengamma.engine.marketdata.spec.MarketData;
import com.opengamma.engine.view.ViewComputationResultModel;
import com.opengamma.engine.view.ViewDefinition;
import com.opengamma.engine.view.ViewDeltaResultModel;
import com.opengamma.engine.view.ViewProcessor;
import com.opengamma.engine.view.ViewResultEntry;
import com.opengamma.engine.view.client.ViewClient;
import com.opengamma.engine.view.client.ViewResultMode;
import com.opengamma.engine.view.compilation.CompiledViewDefinition;
import com.opengamma.engine.view.cycle.ViewCycleMetadata;
import com.opengamma.engine.view.execution.ExecutionOptions;
import com.opengamma.engine.view.execution.ViewCycleExecutionOptions;
import com.opengamma.engine.view.listener.ViewResultListener;
import com.opengamma.id.UniqueId;
import com.opengamma.livedata.UserPrincipal;
import com.opengamma.master.config.ConfigDocument;
import com.opengamma.master.config.ConfigMaster;
import com.opengamma.master.config.ConfigSearchRequest;
import com.opengamma.master.config.ConfigSearchResult;
import com.opengamma.master.config.impl.RemoteConfigMaster;

/**
 * Hello world!
 *
 */
public class ClientApp implements ViewResultListener {
  UserPrincipal localUser;
  ViewClient viewClient;
  
  public ClientApp() throws URISyntaxException {
    URI baseUri = URI.create("http://localhost:8080/jax");
    RemoteComponentFactory componentFactory = new RemoteComponentFactory(baseUri);
    ViewProcessor viewProcessor = componentFactory.getViewProcessor("main");
    localUser = UserPrincipal.getLocalUser();
    viewClient = viewProcessor.createViewClient(localUser);
    viewClient.setResultMode(ViewResultMode.FULL_ONLY);
    viewClient.setResultListener(this); 
    ConfigMaster configMaster = new RemoteConfigMaster(new URI("http://localhost:8080/jax/components/ConfigMaster/central"));
    ConfigSearchRequest<ViewDefinition> request = new ConfigSearchRequest<ViewDefinition>();
    request.setName("Equity Portfolio View1");
    request.setType(ViewDefinition.class);
    ConfigSearchResult<ViewDefinition> result = configMaster.search(request);
    UniqueId viewDefinitionId = null;
    for(ConfigDocument cd : result.getDocuments()) {
      viewDefinitionId = cd.getUniqueId();
      System.out.println("found");
    }    
    viewClient.attachToViewProcess(viewDefinitionId, ExecutionOptions.infinite(MarketData.live()));
  }
  
  public UserPrincipal getUser() {
    return localUser;
  }
  
  public void clientShutdown(Exception arg0) {
    System.out.println("Client Shut Down.");
  }

  public void cycleCompleted(ViewComputationResultModel arg0, ViewDeltaResultModel arg1) {
    System.out.println(arg0.getAllOutputValueNames().toString());
    //System.out.println("DOUBLE_CLOSE : " + arg0.getCalculationResult("FairValue"));
    for(ViewResultEntry  resultEntry : arg0.getAllResults()){
      System.out.println(resultEntry.getComputedValue().toString());
    }
    System.out.println("Cycle Completed.");
  }

  public void cycleExecutionFailed(ViewCycleExecutionOptions arg0, Exception arg1) {
    System.out.println("Cycle Execution failed.");
  }

  public void cycleFragmentCompleted(ViewComputationResultModel arg0, ViewDeltaResultModel arg1) {
    System.out.println("Cycle fragment Completed.");
  }

  public void cycleStarted(ViewCycleMetadata arg0) {
    System.out.println("Cycle started.");
  }

  public void processCompleted() {
    System.out.println("Process Completed.");
  }

  public void processTerminated(boolean arg0) {
    System.out.println("Process terminated.");
  }

  public void viewDefinitionCompilationFailed(Instant arg0, Exception arg1) {
    System.out.println("View Defenition Compilation Failed.");
  }

  public void viewDefinitionCompiled(CompiledViewDefinition arg0, boolean arg1) {
    System.out.println("View Defenition Compiled.");
  }
  
  public static void main( String[] args ) throws URISyntaxException {
    ClientApp client = new ClientApp();    
  }
}