void configureHooksOnRunningMember(MemberVM server, int bucketId) {
    server.invoke(() -> InitialImageOperation.setGIITestHook(new InitialImageOperation.GIITestHook(
        InitialImageOperation.GIITestHookType.BeforeRequestRVV,
        "_B__" + REGION_NAME + "_" + bucketId) {
      private static final long serialVersionUID = -3790198435185240444L;

      @Override
      public void reset() {}

      @Override
      public void run() {
        doPutsInServerTransaction();
        ParallelGatewaySenderAndCQDurableClientDUnitTest.IS_HOOK_TRIGGERED = true;
        if (sizeOfBucketToTempQueueMap("ln") != 0) {
          ParallelGatewaySenderAndCQDurableClientDUnitTest.IS_TEMP_QUEUE_USED = true;
        }
      }
    }));
  }
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