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

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

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

RegionAttributes.getCacheListeners介绍

[英]Returns an array of all the cache listeners on this attributes. Modifications to the returned array will not effect the attributes.
[中]返回此属性上所有缓存侦听器的数组。对返回数组的修改不会影响属性。

代码示例

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

/**
 * This method will return an empty array if there are no CacheListeners defined on the region. If
 * there are one or more than 1 CacheListeners defined, this method will return an array which has
 * the description of all the CacheListeners
 *
 * @return String[] the region's <code>CacheListeners</code> descriptions as a String array
 * @since GemFire 6.0
 */
@Override
public String[] getCacheListeners() {
 Object[] o = this.ra.getCacheListeners();
 String[] ret = null;
 if (o == null || o.length == 0) {
  ret = new String[0];
 } else {
  ret = new String[o.length];
  for (int i = 0; i < o.length; i++) {
   ret[i] = o[i].toString();
  }
 }
 return ret;
}

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

private boolean regionHasExpirationListenerAttached(Region<?, ?> region) {
 return Arrays.stream(region.getAttributes().getCacheListeners())
   .anyMatch(x -> x instanceof SessionExpirationCacheListener);
}

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

@Override
@SuppressWarnings("rawtypes")
public void removeCacheListener() {
 AttributesMutator mutator = this.region.getAttributesMutator();
 CacheListener[] listeners = this.region.getAttributes().getCacheListeners();
 for (int i = 0; i < listeners.length; i++) {
  if (listeners[i] instanceof SerialSecondaryGatewayListener) {
   mutator.removeCacheListener(listeners[i]);
   break;
  }
 }
}

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

private PartitionAttributes initializeAttributes(final Cache cache) {
 PartitionAttributes partitionAttributes = mock(PartitionAttributes.class);
 RegionAttributes attributes = mock(RegionAttributes.class);
 when(attributes.getCacheListeners()).thenReturn(new CacheListener[0]);
 when(attributes.getRegionTimeToLive()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getRegionIdleTimeout()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getEntryTimeToLive()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getEntryIdleTimeout()).thenReturn(ExpirationAttributes.DEFAULT);
 when(attributes.getMembershipAttributes()).thenReturn(new MembershipAttributes());
 when(cache.getRegionAttributes(RegionShortcut.PARTITION.toString())).thenReturn(attributes);
 when(partitionAttributes.getTotalNumBuckets()).thenReturn(113);
 return partitionAttributes;
}

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

.isNotNull();
final CountingDistCacheListener<Object, Object> cdcl =
  (CountingDistCacheListener<Object, Object>) re.getAttributes().getCacheListeners()[0];

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

if (!equal(this.cacheListeners, Arrays.asList(other.getCacheListeners()))) {
 throw new RuntimeException(
   "CacheListeners are not the same");

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

assertEquals(Arrays.asList(new CacheListener[0]), Arrays.asList(ra.getCacheListeners()));
assertEquals(Arrays.asList(new CacheListener[] {cl1}), Arrays.asList(ra.getCacheListeners()));
assertEquals(Arrays.asList(new CacheListener[] {cl2}), Arrays.asList(ra.getCacheListeners()));
assertEquals(Arrays.asList(new CacheListener[0]), Arrays.asList(ra.getCacheListeners()));
  Arrays.asList(ra.getCacheListeners()));
assertEquals(Arrays.asList(new CacheListener[0]), Arrays.asList(ra.getCacheListeners()));
assertEquals(Arrays.asList(new CacheListener[0]), Arrays.asList(ra.getCacheListeners()));
assertEquals(Arrays.asList(new CacheListener[] {cl1}), Arrays.asList(ra.getCacheListeners()));
factory.addCacheListener(cl2);
ra = factory.create();
assertEquals(Arrays.asList(new CacheListener[] {cl1, cl2}),
  Arrays.asList(ra.getCacheListeners()));
factory.initCacheListeners(new CacheListener[] {cl2});
ra = factory.create();
assertEquals(Arrays.asList(new CacheListener[] {cl2}), Arrays.asList(ra.getCacheListeners()));

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

CacheListener<?, ?>[] cacheListeners = ra.getCacheListeners();

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

CacheListener[] listeners = regAttrs.getCacheListeners();

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

CacheListener[] listeners = attrs.getCacheListeners();
for (int i = 0; i < listeners.length; i++) {
 generate(CACHE_LISTENER, listeners[i]);

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

this.cacheListeners = new ArrayList(Arrays.asList(attrs.getCacheListeners()));
this.gatewaySenderIds = new HashSet<String>(attrs.getGatewaySenderIds());
this.asyncEventQueueIds = new HashSet<String>(attrs.getAsyncEventQueueIds());

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

storeCacheListenersField(attrs.getCacheListeners());
assignCacheLoader(attrs.getCacheLoader());
assignCacheWriter(attrs.getCacheWriter());

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

synchronized (this.regionAttributes) {
 this.regionAttributes.cacheListeners =
   new ArrayList<>(Arrays.asList(regionAttributes.getCacheListeners()));

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

this.cacheLoaderDesc = getDesc(attr.getCacheLoader());
this.cacheWriterDesc = getDesc(attr.getCacheWriter());
this.cacheListenerDescs = getDescs(attr.getCacheListeners());
this.keyConstraint = attr.getKeyConstraint();
this.valueConstraint = attr.getValueConstraint();

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

assertNull(attrs.getCacheWriter());
assertNull(attrs.getCacheListener());
assertEquals(Arrays.asList(new CacheListener[0]), Arrays.asList(attrs.getCacheListeners()));
assertEquals(0, attrs.getRegionTimeToLive().getTimeout());
assertEquals(0, attrs.getRegionIdleTimeout().getTimeout());

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

if (parentIsUserSpecified) {
 if (parentWithHas.hasCacheListeners()) {
  initCacheListeners(parent.getCacheListeners());
 initCacheListeners(parent.getCacheListeners());

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

mock(RegionAttributes.class, mockObjectIdentifier("MockRegionAttributes"));
when(mockRegionAttributes.getCacheListeners())
  .thenAnswer(newGetter(() -> cacheListeners.toArray(new CacheListener[cacheListeners.size()])));

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

new CopyOnWriteArrayList<>(nullSafeArray(baseRegionAttributes.getCacheListeners(), CacheListener.class));
  .thenAnswer(invocation -> asSet(asyncEventQueueIds.toArray(new String[asyncEventQueueIds.size()])));
when(mockRegionAttributes.getCacheListeners())
  .thenAnswer(invocation -> cacheListeners.toArray(new CacheListener[cacheListeners.size()]));

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

private Optional<String> configureWithRegionAttributes(ClientRegionFactory<K, V> clientRegionFactory) {
  AtomicReference<String> regionAttributesPoolName = new AtomicReference<>(null);
  Optional.ofNullable(getAttributes()).ifPresent(regionAttributes -> {
    regionAttributesPoolName.set(regionAttributes.getPoolName());
    stream(nullSafeArray(regionAttributes.getCacheListeners(), CacheListener.class))
      .forEach(clientRegionFactory::addCacheListener);
    clientRegionFactory.setCloningEnabled(regionAttributes.getCloningEnabled());
    clientRegionFactory.setCompressor(regionAttributes.getCompressor());
    clientRegionFactory.setConcurrencyChecksEnabled(regionAttributes.getConcurrencyChecksEnabled());
    clientRegionFactory.setConcurrencyLevel(regionAttributes.getConcurrencyLevel());
    clientRegionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
    clientRegionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
    clientRegionFactory.setDiskStoreName(regionAttributes.getDiskStoreName());
    clientRegionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
    clientRegionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
    clientRegionFactory.setEntryTimeToLive(regionAttributes.getEntryTimeToLive());
    clientRegionFactory.setEvictionAttributes(regionAttributes.getEvictionAttributes());
    clientRegionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
    clientRegionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
    clientRegionFactory.setLoadFactor(regionAttributes.getLoadFactor());
    clientRegionFactory.setRegionIdleTimeout(regionAttributes.getRegionIdleTimeout());
    clientRegionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
    clientRegionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
    clientRegionFactory.setValueConstraint(regionAttributes.getValueConstraint());
  });
  return Optional.ofNullable(regionAttributesPoolName.get()).filter(StringUtils::hasText);
}

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

private Optional<String> configureWithRegionAttributes(ClientRegionFactory<K, V> clientRegionFactory) {
  AtomicReference<String> regionAttributesPoolName = new AtomicReference<>(null);
  Optional.ofNullable(getAttributes()).ifPresent(regionAttributes -> {
    regionAttributesPoolName.set(regionAttributes.getPoolName());
    stream(nullSafeArray(regionAttributes.getCacheListeners(), CacheListener.class))
      .forEach(clientRegionFactory::addCacheListener);
    clientRegionFactory.setCloningEnabled(regionAttributes.getCloningEnabled());
    clientRegionFactory.setCompressor(regionAttributes.getCompressor());
    clientRegionFactory.setConcurrencyChecksEnabled(regionAttributes.getConcurrencyChecksEnabled());
    clientRegionFactory.setConcurrencyLevel(regionAttributes.getConcurrencyLevel());
    clientRegionFactory.setCustomEntryIdleTimeout(regionAttributes.getCustomEntryIdleTimeout());
    clientRegionFactory.setCustomEntryTimeToLive(regionAttributes.getCustomEntryTimeToLive());
    clientRegionFactory.setDiskStoreName(regionAttributes.getDiskStoreName());
    clientRegionFactory.setDiskSynchronous(regionAttributes.isDiskSynchronous());
    clientRegionFactory.setEntryIdleTimeout(regionAttributes.getEntryIdleTimeout());
    clientRegionFactory.setEntryTimeToLive(regionAttributes.getEntryTimeToLive());
    clientRegionFactory.setEvictionAttributes(regionAttributes.getEvictionAttributes());
    clientRegionFactory.setInitialCapacity(regionAttributes.getInitialCapacity());
    clientRegionFactory.setKeyConstraint(regionAttributes.getKeyConstraint());
    clientRegionFactory.setLoadFactor(regionAttributes.getLoadFactor());
    clientRegionFactory.setRegionIdleTimeout(regionAttributes.getRegionIdleTimeout());
    clientRegionFactory.setRegionTimeToLive(regionAttributes.getRegionTimeToLive());
    clientRegionFactory.setStatisticsEnabled(regionAttributes.getStatisticsEnabled());
    clientRegionFactory.setValueConstraint(regionAttributes.getValueConstraint());
  });
  return Optional.ofNullable(regionAttributesPoolName.get()).filter(StringUtils::hasText);
}

内容来源于网络，如有侵权，请联系作者删除！

RegionAttributes

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    RegionAttributes类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com