@Test
  public void testPut_CallBackWithResolver() {
    Properties props = getDistributedSystemProperties();
    props.setProperty(SERIALIZABLE_OBJECT_FILTER, "*");

    member1.invoke(() -> {
      cache.set(new CacheFactory(props).create());
      FixedPartitionAttributes fpa = createFixedPartition(QUARTER_1, true, 3);
      createPartitionedRegion("Quarter", singletonList(fpa), 0, 40, 12, null);
    });

    member2.invoke(() -> {
      cache.set(new CacheFactory(props).create());
      FixedPartitionAttributes fpa = createFixedPartition(QUARTER_2, true, 3);
      createPartitionedRegion("Quarter", singletonList(fpa), 0, 40, 12, null);
    });

    member3.invoke(() -> {
      cache.set(new CacheFactory(props).create());
      FixedPartitionAttributes fpa = createFixedPartition(QUARTER_3, true, 3);
      createPartitionedRegion("Quarter", singletonList(fpa), 0, 40, 12, null);
    });

    member4.invoke(() -> {
      cache.set(new CacheFactory(props).create());
      FixedPartitionAttributes fpa = createFixedPartition(QUARTER_4, true, 3);
      createPartitionedRegion("Quarter", singletonList(fpa), 0, 40, 12, null);
    });

    member1.invoke(() -> putThroughDataStore_CallBackWithResolver("Quarter"));

    member1.invoke(() -> checkPrimaryData(QUARTER_1));
    member2.invoke(() -> checkPrimaryData(QUARTER_2));
    member3.invoke(() -> checkPrimaryData(QUARTER_3));
    member4.invoke(() -> checkPrimaryData(QUARTER_4));

    member1.invoke(() -> checkPrimaryBucketsForQuarter(3, 3));
    member2.invoke(() -> checkPrimaryBucketsForQuarter(3, 3));
    member3.invoke(() -> checkPrimaryBucketsForQuarter(3, 3));
    member4.invoke(() -> checkPrimaryBucketsForQuarter(3, 3));
  }
This tests validate that datastore member tries the put with callback on itself as well as
other datastores as per primary FixedPartitionAttributes defined on datastores. here CallBack
implements FixedPartitionResolver.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/fixed/FixedPartitioningDUnitTest.java