本文整理了Java中org.apache.geode.cache.RegionAttributes.getSubscriptionAttributes
方法的一些代码示例,展示了RegionAttributes.getSubscriptionAttributes
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegionAttributes.getSubscriptionAttributes
方法的具体详情如下:
包路径:org.apache.geode.cache.RegionAttributes
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!