private void validateSubstitutionFilterToDataInvocations(int expectedToDataInvocations) {
    // Verify the GatewayEventSubstitutionFilter has been invoked the appropriate number of times
    SizeableGatewayEventSubstitutionFilter filter = getSizeableGatewayEventSubstitutionFilter();
    assertThat(filter.getNumToDataInvocations()).isEqualTo(expectedToDataInvocations);
  }
Override as needed to add to the configuration, such as regionFactory.setOffHeap(boolean).
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerWithFilterDistributedTest.java