GEODE-1617: CreateRegionFunction was not attaching a cache listener
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/f0d36eea Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/f0d36eea Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/f0d36eea Branch: refs/heads/master Commit: f0d36eea5da1102d7293fd2fd573c7ad3ae01d66 Parents: 408189c Author: Jason Huynh <[email protected]> Authored: Mon Jul 25 14:34:17 2016 -0700 Committer: Jason Huynh <[email protected]> Committed: Mon Jul 25 14:48:57 2016 -0700 ---------------------------------------------------------------------- .../com/gemstone/gemfire/modules/util/CreateRegionFunction.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/f0d36eea/extensions/geode-modules/src/main/java/com/gemstone/gemfire/modules/util/CreateRegionFunction.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules/src/main/java/com/gemstone/gemfire/modules/util/CreateRegionFunction.java b/extensions/geode-modules/src/main/java/com/gemstone/gemfire/modules/util/CreateRegionFunction.java index 342968c..a9c9322 100644 --- a/extensions/geode-modules/src/main/java/com/gemstone/gemfire/modules/util/CreateRegionFunction.java +++ b/extensions/geode-modules/src/main/java/com/gemstone/gemfire/modules/util/CreateRegionFunction.java @@ -218,12 +218,11 @@ public class CreateRegionFunction implements Function, Declarable { if (r != null) { return r; } - RegionFactory<String, RegionConfiguration> factory = this.cache.createRegionFactory(RegionShortcut.REPLICATE); - factory.addCacheListener(new RegionConfigurationCacheListener()); GemFireCacheImpl gemFireCache = (GemFireCacheImpl) cache; InternalRegionArguments ira = new InternalRegionArguments().setInternalRegion(true); AttributesFactory af = new AttributesFactory(); af.setScope(Scope.LOCAL); + af.addCacheListener(new RegionConfigurationCacheListener()); RegionAttributes ra = af.create(); try { return gemFireCache.createVMRegion(REGION_CONFIGURATION_METADATA_REGION, ra, ira);
