public static void checkPRQLocalSize(String senderId, final int numQueueEntries) {
    GatewaySender sender = null;
    for (GatewaySender s : cache.getGatewaySenders()) {
      if (s.getId().equals(senderId)) {
        sender = s;
        break;
      }
    }
    assertThat(sender).isNotNull();

    if (sender.isParallel()) {
      final Set<RegionQueue> queues = ((AbstractGatewaySender) sender).getQueues();
      await().untilAsserted(() -> {
        int size = 0;
        for (RegionQueue q : queues) {
          ConcurrentParallelGatewaySenderQueue prQ = (ConcurrentParallelGatewaySenderQueue) q;
          size += prQ.localSize();
        }
        assertThat(size).as(
            " Expected local queue entries: " + numQueueEntries + " but actual entries: " + size)
            .isEqualTo(numQueueEntries);
      });
    }
  }
To be used only for ParallelGatewaySender.

@param senderId Id of the ParallelGatewaySender
@param numQueueEntries Expected number of ParallelGatewaySenderQueue entries
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java