public class NodeListener implements NodeLifeCycleListener {
  @Override
  public void nodeStarting(final NodeLifeCycleEvent event) { }
 
  @Override
  public void nodeEnding(final NodeLifeCycleEvent event) { }
 
  @Override
  public void jobStarting(final NodeLifeCycleEvent event) {
    System.out.println("test.NodeListener: job starting");
    JPPFTask task = (JPPFTask) event.getTasks().get(0);
    Class c = task.getClass();
    System.out.println("task=" + task + ", class=" + c + ", classloader=" + c.getClassLoader());
    System.out.println("task object=" + task.getTaskObject());
  }
 
  @Override
  public void jobEnding(final NodeLifeCycleEvent event) { }
}

public class Main {
  public static void main(final String[] args) {
    JPPFClient client = new JPPFClient();
    JPPFExecutorService executor = new JPPFExecutorService(client);
    try {
      while (!client.hasAvailableConnection()) Thread.sleep(10L);
      List<Future<?>> futures = new ArrayList<Future<?>>();
      futures.add(executor.submit(new MyRunnableTask()));
      futures.get(i).get();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      executor.shutdownNow();
      client.close();
    }
  }
 
  public static class MyRunnableTask implements Runnable, Serializable {
    @Override
    public void run() {
      System.out.println("running MyRunnableTask");
    }
  }
}