本文整理了Java中org.apache.geode.cache.RegionAttributes.getEnableAsyncConflation
方法的一些代码示例,展示了RegionAttributes.getEnableAsyncConflation
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getEnableAsyncConflation
方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称:RegionAttributes
方法名:getEnableAsyncConflation
[英]Returns whether or not async conflation is enabled for sending messages to async peers. Default is false.
[中]返回是否启用异步合并以向异步对等方发送消息。默认值为false。
代码示例来源:origin: apache/geode
"Enable Subscription Conflation is not the same");
if (this.enableAsyncConflation != other.getEnableAsyncConflation()) {
throw new RuntimeException(
"Enable Async Conflation is not the same");
代码示例来源:origin: apache/geode
dataPolicy = ra.getDataPolicy();
diskStoreName = ra.getDiskStoreName();
enableAsyncConflation = ra.getEnableAsyncConflation();
enableSubscriptionConflation = ra.getEnableSubscriptionConflation();
ignoreJTA = ra.getIgnoreJTA();
代码示例来源:origin: apache/geode
if (generateDefaults() || attrs.getEnableAsyncConflation())
atts.addAttribute("", "", ENABLE_ASYNC_CONFLATION, "",
String.valueOf(attrs.getEnableAsyncConflation()));
代码示例来源:origin: apache/geode
boolean asyncConflationEnabled = regAttrs.getEnableAsyncConflation();
String poolName = regAttrs.getPoolName();
boolean isCloningEnabled = regAttrs.getCloningEnabled();
代码示例来源:origin: apache/geode
this.enableSubscriptionConflation = attrs.getEnableSubscriptionConflation();
this.publisher = attrs.getPublisher();
this.enableAsyncConflation = attrs.getEnableAsyncConflation();
this.poolName = attrs.getPoolName();
this.multicastEnabled = attrs.getMulticastEnabled();
代码示例来源:origin: apache/geode
this.enableSubscriptionConflation = attrs.getEnableSubscriptionConflation();
this.publisher = attrs.getPublisher();
this.enableAsyncConflation = attrs.getEnableAsyncConflation();
this.indexMaintenanceSynchronous = attrs.getIndexMaintenanceSynchronous();
this.mcastEnabled = attrs.getMulticastEnabled();
代码示例来源:origin: apache/geode
this.regionAttributes.enableAsyncConflation = regionAttributes.getEnableAsyncConflation();
this.regionAttributes.enableSubscriptionConflation =
regionAttributes.getEnableSubscriptionConflation();
代码示例来源:origin: apache/geode
this.enableAsyncConflation = attr.getEnableAsyncConflation();
this.diskStoreName = attr.getDiskStoreName();
if (this.diskStoreName == null) {
代码示例来源:origin: apache/geode
if (parentIsUserSpecified) {
if (parentWithHas.hasEnableAsyncConflation()) {
setEnableAsyncConflation(parent.getEnableAsyncConflation());
setEnableAsyncConflation(parent.getEnableAsyncConflation());
代码示例来源:origin: org.springframework.data/spring-data-geode-test
when(mockRegionAttributes.getDiskStoreName()).thenAnswer(newGetter(diskStoreName));
when(mockRegionAttributes.isDiskSynchronous()).thenAnswer(newGetter(diskSynchronous));
when(mockRegionAttributes.getEnableAsyncConflation()).thenAnswer(newGetter(enableAsyncConflation));
when(mockRegionAttributes.getEnableSubscriptionConflation()).thenAnswer(newGetter(enableSubscriptionConflation));
when(mockRegionAttributes.getEntryIdleTimeout()).thenAnswer(newGetter(entryIdleTimeout));
代码示例来源:origin: org.springframework.data/spring-data-geode-test
when(mockRegionAttributes.getDataPolicy()).thenAnswer(newGetter(baseRegionAttributes::getDataPolicy));
when(mockRegionAttributes.getDiskStoreName()).thenAnswer(newGetter(baseRegionAttributes::getDiskStoreName));
when(mockRegionAttributes.getEnableAsyncConflation()).thenAnswer(newGetter(baseRegionAttributes::getEnableAsyncConflation));
when(mockRegionAttributes.getEnableSubscriptionConflation()).thenAnswer(newGetter(baseRegionAttributes::getEnableSubscriptionConflation));
when(mockRegionAttributes.getEntryIdleTimeout()).thenAnswer(newGetter(entryIdleTimeout::get));
代码示例来源:origin: org.springframework.data/spring-data-geode
regionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
regionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
regionFactory.setEnableAsyncConflation(regionAttributes.getEnableAsyncConflation());
regionFactory.setEnableSubscriptionConflation(regionAttributes.getEnableSubscriptionConflation());
regionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
代码示例来源:origin: org.springframework.data/spring-data-gemfire
regionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
regionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
regionFactory.setEnableAsyncConflation(regionAttributes.getEnableAsyncConflation());
regionFactory.setEnableSubscriptionConflation(regionAttributes.getEnableSubscriptionConflation());
regionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
内容来源于网络,如有侵权,请联系作者删除!