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

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

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

RegionAttributes.getSubscriptionAttributes介绍

[英]Returns the SubscriptionAttributes that configure how this region behaves as a subscriber to remote caches.
[中]返回SubscriptionAttributes,用于配置此区域作为远程缓存订阅服务器的行为。

代码示例

代码示例来源:origin: apache/geode

@Override
public SubscriptionAttributes getSubscriptionAttributes() {
 return this.ra.getSubscriptionAttributes();
}

代码示例来源:origin: apache/geode

"Membership Attributes are not the same");
if (!equal(this.subscriptionAttributes, other.getSubscriptionAttributes())) {
 throw new RuntimeException(
   "Subscription Attributes are not the same");

代码示例来源:origin: apache/geode

String diskStoreName = regAttrs.getDiskStoreName();
String interestPolicy = null;
if (regAttrs.getSubscriptionAttributes() != null) {
 interestPolicy = regAttrs.getSubscriptionAttributes().getInterestPolicy().toString();

代码示例来源:origin: apache/geode

if ((!(attrs instanceof RegionAttributesCreation)
  || ((RegionAttributesCreation) attrs).hasSubscriptionAttributes())) {
 SubscriptionAttributes sa = attrs.getSubscriptionAttributes();
 if (sa != null) {
  if (generateDefaults() || !sa.equals(new SubscriptionAttributes()))

代码示例来源:origin: apache/geode

this.partitionAttributes = attrs.getPartitionAttributes();
this.membershipAttributes = attrs.getMembershipAttributes();
this.subscriptionAttributes = attrs.getSubscriptionAttributes();
this.dataPolicy = attrs.getDataPolicy();
this.evictionAttributes = (EvictionAttributesImpl) attrs.getEvictionAttributes();

代码示例来源:origin: apache/geode

this.partitionAttributes = attrs.getPartitionAttributes();
this.membershipAttributes = attrs.getMembershipAttributes();
this.subscriptionAttributes = attrs.getSubscriptionAttributes();
this.cloningEnable = attrs.getCloningEnabled();
this.poolName = attrs.getPoolName();

代码示例来源:origin: apache/geode

this.regionAttributes.subscriptionAttributes = regionAttributes.getSubscriptionAttributes();
this.regionAttributes.evictionAttributes =
  (EvictionAttributesImpl) regionAttributes.getEvictionAttributes();

代码示例来源:origin: apache/geode

this.subscriptionAttributes = attr.getSubscriptionAttributes();
this.cloningEnable = attr.getCloningEnabled();
this.poolName = attr.getPoolName();

代码示例来源:origin: apache/geode

assertEquals(new SubscriptionAttributes(InterestPolicy.ALL), ra.getSubscriptionAttributes());
assertEquals(new SubscriptionAttributes(InterestPolicy.ALL), ra.getSubscriptionAttributes());
assertEquals(new SubscriptionAttributes(InterestPolicy.ALL), ra.getSubscriptionAttributes());
assertEquals(new SubscriptionAttributes(InterestPolicy.ALL), ra.getSubscriptionAttributes());

代码示例来源:origin: apache/geode

assertEquals(Scope.DISTRIBUTED_NO_ACK, attrs.getScope());
assertEquals(DataPolicy.DEFAULT, attrs.getDataPolicy());
assertEquals(InterestPolicy.DEFAULT, attrs.getSubscriptionAttributes().getInterestPolicy());
assertEquals(MirrorType.NONE, attrs.getMirrorType());
assertEquals(null, attrs.getDiskStoreName());

代码示例来源:origin: apache/geode

if (parentIsUserSpecified) {
 if (parentWithHas.hasSubscriptionAttributes()) {
  setSubscriptionAttributes(parent.getSubscriptionAttributes());
 setSubscriptionAttributes(parent.getSubscriptionAttributes());

代码示例来源:origin: org.springframework.data/spring-data-geode-test

when(mockRegionAttributes.getScope()).thenAnswer(newGetter(scope));
when(mockRegionAttributes.getStatisticsEnabled()).thenAnswer(newGetter(statisticsEnabled));
when(mockRegionAttributes.getSubscriptionAttributes()).thenAnswer(newGetter(subscriptionAttributes));
when(mockRegionAttributes.getValueConstraint()).thenAnswer(newGetter(valueConstraint));

代码示例来源:origin: org.springframework.data/spring-data-geode-test

when(mockRegionAttributes.getScope()).thenAnswer(newGetter(baseRegionAttributes::getScope));
when(mockRegionAttributes.getStatisticsEnabled()).thenAnswer(newGetter(baseRegionAttributes::getStatisticsEnabled));
when(mockRegionAttributes.getSubscriptionAttributes()).thenAnswer(newGetter(baseRegionAttributes::getSubscriptionAttributes));
when(mockRegionAttributes.getValueConstraint()).thenAnswer(newGetter(baseRegionAttributes::getValueConstraint));
when(mockRegionAttributes.isDiskSynchronous()).thenAnswer(newGetter(baseRegionAttributes::isDiskSynchronous));

代码示例来源:origin: org.springframework.data/spring-data-geode

regionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
regionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
regionFactory.setSubscriptionAttributes(regionAttributes.getSubscriptionAttributes());
regionFactory.setValueConstraint(regionAttributes.getValueConstraint());

代码示例来源:origin: org.springframework.data/spring-data-gemfire

regionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
regionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
regionFactory.setSubscriptionAttributes(regionAttributes.getSubscriptionAttributes());
regionFactory.setValueConstraint(regionAttributes.getValueConstraint());

相关文章

微信公众号

最新文章

更多

RegionAttributes类方法