public class DialogProgressProvider extends ProgressProvider {
  public IProgressMonitor createMonitor(final Job job) {
    final IProgressMonitor[] m = new IProgressMonitor[]{
      new NullProgressMonitor()};
    Display.getDefault().syncExec(new Runnable() {
      public void run() {
        final ProgressMonitorDialog dialog =
            new NonBlockingProgressMonitorDialog(
                Display.getDefault().getActiveShell());
        dialog.setBlockOnOpen(false);
        dialog.setCancelable(true);
        dialog.open();
        job.addJobChangeListener(new JobChangeAdapter() {
          public void done(IJobChangeEvent event) {
            // what if the job returned an error?
            close(dialog);
          }
        });
        m[0] = new AccumulatingProgressMonitor(
          dialog.getProgressMonitor(), Display.getDefault());
      }
    });
    return m[0];
  }

	public void doRun(@Optional IProgressMonitor monitor) throws IOException,
	InterruptedException {
		if(monitor == null)  {
			monitor = new NullProgressMonitor();
		}
		Display display = parent.getDisplay();
		if (!(display==null || display.isDisposed())) {
			display.asyncExec(new Runnable () {
				public void run() {
					// Use OSGi extension to invoke test engine 
					// Use the unchanged version, i.e. original
					TestCase original = testCaseComposite.getOriginalTestCase();
					final String[] testToRun = new String[6];
					if(!original.isValid()) {
						// Output to status window and return
					}
					// Hmmm smells a bit
					testToRun[0] = original.getInboundMetaFile();
					testToRun[1] = original.getOutboundMetaFile();
					testToRun[2] = original.getInboundDataFile();
					testToRun[3] = original.getOutboundDataFile();
					testToRun[4] = original.getMappingMetaFile();

					IConfigurationElement[] config = Platform.getExtensionRegistry()
							.getConfigurationElementsFor(ITESTER_ID);
					try {
						for (IConfigurationElement e : config) {
							System.out.println("Evaluating extension");
							final Object o = e.createExecutableExtension("class");
							if (o instanceof IFlatFileTester) {
								ISafeRunnable runnable = new ISafeRunnable() {
									@Override
									public void handleException(Throwable exception) {
										System.out.println("Exception in Test engine");
									}
		
									@Override
									public void run() throws Exception {
										((IFlatFileTester) o).run(testToRun);
									}
								};
								SafeRunner.run(runnable);
							}
						}
					} catch (CoreException ex) {
						System.out.println(ex.getMessage());
					}
				}
			});
		}
	}