protected void clearAllTempQueueForShadowPR(final int bucketId) {
    List<PartitionedRegion> colocatedWithList =
        ColocationHelper.getColocatedChildRegions(partitionedRegion);
    for (PartitionedRegion childRegion : colocatedWithList) {
      if (childRegion.isShadowPR()) {
        AbstractGatewaySender sender = childRegion.getParallelGatewaySender();
        if (sender == null) {
          return;
        }
        AbstractGatewaySenderEventProcessor eventProcessor = sender.getEventProcessor();
        if (eventProcessor == null) {
          return;
        }

        ConcurrentParallelGatewaySenderQueue queue =
            (ConcurrentParallelGatewaySenderQueue) eventProcessor.getQueue();

        if (queue == null) {
          return;
        }
        BlockingQueue<GatewaySenderEventImpl> tempQueue = queue.getBucketTmpQueue(bucketId);
        if (tempQueue != null) {
          synchronized (tempQueue) {
            for (GatewaySenderEventImpl event : tempQueue) {
              event.release();
            }
            tempQueue.clear();
          }
        }
      }
    }
  }
Attempts to map a bucket id to this node. Creates real storage for the bucket by adding a new
Region to bucket2Map. Bucket creation is done under the d-lock on b2n region.

@param possiblyFreeBucketId the identity of the bucket + @param mustBeNew boolean enforcing
       that the bucket must not already exist
@param sender the member requesting the bucket
@param moveSource Where we are moving the bucket from, if this is a move.
@param forceCreation avoid any checks (with in reason) which might prevent bucket creation
@param isRebalance true if bucket creation is directed by rebalancing
@return true if successful
geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java