org.apache.geode.cache.RegionAttributes.getEnableAsyncConflation()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(62)

本文整理了Java中org.apache.geode.cache.RegionAttributes.getEnableAsyncConflation方法的一些代码示例,展示了RegionAttributes.getEnableAsyncConflation的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getEnableAsyncConflation方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称:RegionAttributes
方法名:getEnableAsyncConflation

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());

相关文章

微信公众号

最新文章

更多

RegionAttributes类方法