private void startDurableClient()
      throws Exception {
    int locatorPort = locatorSite2.getPort();
    clientSite2DurableSubscription = clusterStartupRule.startClientVM(7, ccf -> ccf
        .withPoolSubscription(true).withLocatorConnection(locatorPort).withCacheSetup(c -> c
            .set(ConfigurationProperties.DURABLE_CLIENT_ID, DURABLE_CLIENT_ID)));
  }
This hook will run some transaction traffic after server requested initial image from
primary bucket server, and then it will check if events are enqueued in temporary queue.
It is expected that events are enqueued in this case because bucket is not yet available.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderAndCQDurableClientDUnitTest.java