@Test
  public void testInvokeNamedRunnableLambdaAsync() throws Exception {
    Throwable thrown =
        catchThrowable(
            () -> vm0.invokeAsync("throwSomething", BasicDistributedTest::throwException).await());

    assertThat(thrown, notNullValue());
    assertThat(thrown.getCause(), notNullValue());
    assertThat(thrown.getCause(), instanceOf(BasicDUnitException.class));
  }
This class tests the basic functionality of the distributed unit test framework.
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/tests/BasicDistributedTest.java