void doPutsInServerTransaction() {
    Region<String, String> region =
        Objects.requireNonNull(ClusterStartupRule.getCache()).getRegion(REGION_NAME);

    CacheTransactionManager transactionManager =
        ClusterStartupRule.getCache().getCacheTransactionManager();
    for (int i = 0; i < 50; i++) {
      transactionManager.begin();
      region.put(i + "key", i + "value");
      transactionManager.commit();
    }
  }
Checks that the bucketToTempQueueMap for a partitioned region
that holds events for buckets that are not available locally, is empty.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderAndCQDurableClientDUnitTest.java