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

EntryEvent.isOriginRemote介绍

暂无

代码示例

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

@Override
public void afterUpdate(EntryEvent<K, V> e) {
 if (e.isOriginRemote()) {
  synchronized (this) {
   ++this.aUpdateCalls;
   this.lastEvent = e;
  }
 }
}

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

@Override
public void afterInvalidate(EntryEvent<K, V> e) {
 if (e.isOriginRemote()) {
  synchronized (this) {
   ++this.aInvalidateCalls;
   this.lastEvent = e;
  }
 }
}

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

@Override
public void afterCreate(EntryEvent<K, V> e) {
 if (e.isOriginRemote()) {
  synchronized (this) {
   ++this.aCreateCalls;
   this.lastEvent = e;
  }
 }
}

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

@Override
public void afterDestroy(EntryEvent<K, V> e) {
 if (e.isOriginRemote()) {
  synchronized (this) {
   ++this.aDestroyCalls;
   this.lastEvent = e;
  }
 }
}

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

@Override
public void afterUpdate(EntryEvent<String, Configuration> event) {
 super.afterUpdate(event);
 if (event.isOriginRemote()) {
  addOrRemoveJarFromFilesystem(event);
 }
}

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

@Override
public void afterCreate(EntryEvent<String, Configuration> event) {
 super.afterCreate(event);
 if (event.isOriginRemote()) {
  addOrRemoveJarFromFilesystem(event);
 }
}

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

private void verifyMirrorRegionEventsMatch(EntryEvent<String, String> event, Region region,
  String expectedValue) {
 assertThat(event.getRegion()).isSameAs(region);
 assertThat(event.getKey()).isEqualTo("key");
 assertThat(event.getNewValue()).isEqualTo(expectedValue);
 assertThat(event.getOldValue()).isNull();
 assertThat(event.getOperation().isLocalLoad()).isFalse();
 assertThat(event.getOperation().isNetLoad()).isFalse();
 assertThat(event.getOperation().isLoad()).isFalse();
 assertThat(event.getOperation().isNetSearch()).isFalse();
 assertThat(event.getOperation().isExpiration()).isFalse();
 assertThat(event.getCallbackArgument()).isNull();
 assertThat(event.isCallbackArgumentAvailable()).isTrue();
 assertThat(event.isOriginRemote()).isTrue();
 assertThat(event.getOperation().isDistributed()).isTrue();
}

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

assertThat(listenEvent.getOperation().isDistributed()).isTrue();
assertThat(listenEvent.getOperation().isExpiration()).isFalse();
assertThat(listenEvent.isOriginRemote()).isTrue();
cdcl.setEntryEvent(null);

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

/**
 * Takes an entry event and processes it. If the entry denotes that a
 * {@link RedisDataType#REDIS_LIST} or {@link RedisDataType#REDIS_SORTEDSET} was created then this
 * function will call the necessary calls to create the parameterized queries for those keys.
 *
 * @param event EntryEvent from meta data region
 */
private void afterKeyCreate(EntryEvent<String, RedisDataType> event) {
 if (event.isOriginRemote()) {
  final String key = (String) event.getKey();
  final RedisDataType value = event.getNewValue();
  if (value != RedisDataType.REDIS_STRING && value != RedisDataType.REDIS_HLL
    && value != RedisDataType.REDIS_PROTECTED) {
   try {
    this.regionCache.createRemoteRegionReferenceLocally(Coder.stringToByteArrayWrapper(key),
      value);
   } catch (RegionDestroyedException ignore) { // Region already destroyed, ignore
   }
  }
 }
}

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

/**
 * When a key is removed then this function will make sure the associated queries with the key are
 * also removed from each vm to avoid unnecessary data retention
 */
private void afterKeyDestroy(EntryEvent<String, RedisDataType> event) {
 if (event.isOriginRemote()) {
  final String key = (String) event.getKey();
  final RedisDataType value = event.getOldValue();
  if (value != null && value != RedisDataType.REDIS_STRING && value != RedisDataType.REDIS_HLL
    && value != RedisDataType.REDIS_PROTECTED) {
   ByteArrayWrapper kW = Coder.stringToByteArrayWrapper(key);
   Region<?, ?> r = this.regionCache.getRegion(kW);
   if (r != null) {
    this.regionCache.removeRegionReferenceLocally(kW, value);
   }
  }
 }
}

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

assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();

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

protected void buildDynamicRegion(EntryEvent event) {
 if (!DynamicRegionFactory.this.isOpen())
  return;
 // Ignore the callback if it originated in this process (because the region
 // will already have been created) and the event is not a client event
 if (!event.isOriginRemote() && !event.hasClientOrigin())
  return;
 //
 DynamicRegionAttributes dra = (DynamicRegionAttributes) event.getNewValue();
 String parentRegionName = dra.rootRegionName;
 String newRegionName = dra.name;
 try {
  doBeforeRegionCreated(parentRegionName, newRegionName);
  Region region = createDynamicRegionImpl(parentRegionName, newRegionName, false);
  doAfterRegionCreated(region, true, true, event.getDistributedMember());
 } catch (Exception e) {
  cache.getLogger().warning(
    String.format("Error attempting to locally create Dynamic Region: %s",
      newRegionName),
    e);
 }
}

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

assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
 assertThat(ev.getCallbackArgument()).isNull();
 assertThat(ev.isCallbackArgumentAvailable()).isTrue();
 assertThat(ev.isOriginRemote()).isFalse();
 assertThat(ev.getOperation().isExpiration()).isFalse();
 assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();

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

assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isTrue();
assertThat(ev.getOperation().isDistributed()).isTrue();

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

assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isTrue();
assertThat(ev.getOperation().isDistributed()).isTrue();

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

event.getOperation().equals(Operation.UPDATE_VERSION_STAMP);
boolean isCME_And_NotOriginRemote =
  ((EntryEventImpl) event).isConcurrencyConflict() && !event.isOriginRemote();
if (!(isUpdateVersionStamp || isCME_And_NotOriginRemote)) {
 senderEvent =

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

assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isTrue();
assertThat(ev.getOperation().isDistributed()).isTrue();