assertFlowStarted(activity);
    public void test() throws Exception {        ExampleParallelBean parallelBean = new ExampleParallelBean();        FindCallableMethods factory = new FindCallableMethods(parallelBean);        ParallelActivity activity = new ParallelActivity(new JoinAll(), executor, factory);        activity.startWithTimeout(timer, -1);        assertFlowStarted(activity);        parallelBean.assertCompleted();                // OK the latch may be completed but the         // join might not have completed yet        Thread.sleep(5000);                // TODO FIXME!        //assertFlowStopped(activity);    }