public class JPPFBroadcastTest {
  public static void main(String[] args) {
    try {
      TypedProperties props = JPPFConfiguration.getProperties();
      props.setBoolean("jppf.discovery.enabled", false);
      props.setString("jppf.drivers", "driver1");
      props.setString("driver1.jppf.server.host", "localhost");
      props.setBoolean("jppf.local.execution.enabled", true);
      props.setBoolean("jppf.remote.execution.enabled", true);
      props.setString("jppf.load.balancing.algorithm", "manual");
      props.setString("jppf.load.balancing.profile", "manual");
      props.setInt("jppf.load.balancing.profile.manual.size", 10);
      JPPFClient jppfClient = new JPPFClient();
      JPPFExecutorService  executor = new JPPFExecutorService(jppfClient);
      ExecutorServiceConfiguration config = executor.getConfiguration();
      JobConfiguration jobConfig = config.getJobConfiguration();
      jobConfig.getClientSLA().setMaxChannels(2);
      jobConfig.getSLA().setBroadcastJob(true);
      Future<?> future = executor.submit(new JPPFTestTask(1));
      future.get();
      executor.shutdownNow();
    } catch(Exception e) {
      e.printStackTrace();
    }
  }
}