EmbeddedCacheManager cm2 = TestCacheManagerFactory.createCacheManager(GlobalConfiguration.getClusteredDefault());
try {
cm1.defineConfiguration("r", replCfg);
cm1.defineConfiguration("d", distCfg);
cm2.defineConfiguration("r", replCfg);
cm2.defineConfiguration("d", distCfg);
// first start the repl caches
Cache<String, String> c1r = startCache(cm1, "r", false).get();
c1r.put("key", "value");
Cache<String, String> c2r = startCache(cm2, "r", false).get();