/**
 * Copyright (c) 2012-2012 Malhar, Inc.
 * All rights reserved.
 */
package com.malhartech.demos.performance;

import com.malhartech.stram.StramLocalCluster;
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.junit.Test;

/**
 * Test the DAG declaration in local mode.
 */
public class ApplicationTest
{
  @Test
  public void testApplication() throws IOException, Exception
  {
    Application app = new Application();
    final StramLocalCluster lc = new StramLocalCluster(app.getApplication(new Configuration(false)));

    new Thread("LocalClusterController")
    {
      @Override
      public void run()
      {
        try {
          Thread.sleep(60000);
        }
        catch (InterruptedException ex) {
        }

        lc.shutdown();
      }
    }.start();

    lc.run();
  }
}

@@ -555,270 +555,24 @@
 ));%0A
-%0A
     
-new Thread(%22LocalClusterController%22)%0A    %7B%0A      @Override%0A      public void run()%0A      %7B%0A        try %7B%0A          Thread.sleep(60000);%0A        %7D%0A        catch (InterruptedException ex) %7B%0A        %7D%0A%0A        lc.shutdown();%0A      %7D%0A    %7D.start();%0A%0A    
 lc.run(
+60000
 );%0A 

Use the new API.