public void initialize(GemFireCacheImpl cache, PartitionedRegion queueRegion) {
    InternalDistributedMember member = cache.getMyId();
    when(queueRegion.getMyId()).thenReturn(member);
    when(cache.getInternalRegionByPath(bucketRegionQueue.getFullPath()))
        .thenReturn(bucketRegionQueue);
  }
Helper class in the internal cache package to access protected BucketRegionQueue methods.
geode-core/src/test/java/org/apache/geode/internal/cache/BucketRegionQueueHelper.java