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

EntryEvent.getOldValue介绍

暂无

代码示例

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

@Override
public void afterDestroy(EntryEvent<String, HttpSession> event) {
 /**
  * A Session expired. If it was destroyed by GemFire expiration, process it. If it was destroyed
  * via Session.invalidate, ignore it since it has already been processed.
  */
 if (event.getOperation() == Operation.EXPIRE_DESTROY) {
  HttpSession session = (HttpSession) event.getOldValue();
  session.invalidate();
 }
}

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

@Override
public void afterDestroy(EntryEvent<String, Object> event) {
 ObjectName objectName = null;
 try {
  objectName = ObjectName.getInstance(event.getKey());
  Object oldObject = event.getOldValue();
  proxyHelper.removeProxy(event.getDistributedMember(), objectName, oldObject);
 } catch (Exception e) {
  if (logger.isDebugEnabled()) {
   logger.debug("Proxy Destroy failed for {} with exception {}", objectName, e.getMessage(),
     e);
  }
 }
}

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

@Override
 public void beforeUpdate(EntryEvent event) throws CacheWriterException {
  // the prConfig node list must advance (otherwise meta data becomes out of sync)
  final PartitionRegionConfig newConf = (PartitionRegionConfig) event.getNewValue();
  final PartitionRegionConfig oldConf = (PartitionRegionConfig) event.getOldValue();
  if (newConf != oldConf && !newConf.isGreaterNodeListVersion(oldConf)) {
   throw new CacheWriterException(
     String.format(
       "New PartitionedRegionConfig %s does not have newer version than previous %s",
       new Object[] {newConf, oldConf}));
  }
 }
});

代码示例来源：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

@Override
public void afterCreate(EntryEvent event) {
 if (logger.isDebugEnabled()) {
  logger.debug(
    "Create Event for allPR: key = {} oldVal = {} newVal = {} Op = {} origin = {} isNetSearch = {}",
    event.getKey(), event.getOldValue(), event.getNewValue(), event.getOperation(),
    event.getDistributedMember(), event.getOperation().isNetSearch());
 }
}

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

@Override
public void afterUpdate(EntryEvent event) {
 if (logger.isDebugEnabled()) {
  logger.debug(
    "Update Event for allPR: key = {} oldVal = {} newVal = {} Op = {} origin = {} isNetSearch = {}",
    event.getKey(), event.getOldValue(), event.getNewValue(), event.getOperation(),
    event.getDistributedMember(), event.getOperation().isNetSearch());
 }
}

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

@Override
 public void afterDestroy(EntryEvent event) {
  if (logger.isDebugEnabled()) {
   logger.debug(
     "Destroy Event for allPR: key = {} oldVal = {} newVal = {} Op = {} origin = {} isNetSearch = {}",
     event.getKey(), event.getOldValue(), event.getNewValue(), event.getOperation(),
     event.getDistributedMember(), event.getOperation().isNetSearch());
  }
 }
});

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

@Override
public void afterUpdate(EntryEvent<String, Object> event) {
 ObjectName objectName = null;
 try {
  if (!readyForEvents) {
   return;
  }
  objectName = ObjectName.getInstance(event.getKey());
  ProxyInfo proxyInfo = proxyHelper.findProxyInfo(objectName);
  if (proxyInfo != null) {
   ProxyInterface proxyObj = (ProxyInterface) proxyInfo.getProxyInstance();
   // Will return null if proxy is filtered out
   if (proxyObj != null) {
    proxyObj.setLastRefreshedTime(System.currentTimeMillis());
   }
   Object oldObject = event.getOldValue();
   Object newObject = event.getNewValue();
   proxyHelper.updateProxy(objectName, proxyInfo, newObject, oldObject);
  }
 } catch (Exception e) {
  if (logger.isDebugEnabled()) {
   logger.debug("Proxy Update failed for {} with exception {}", objectName, e.getMessage(), e);
  }
 }
}

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

private void addOrRemoveJarFromFilesystem(EntryEvent<String, Configuration> event) {
 String group = event.getKey();
 Configuration newConfig = event.getNewValue();
 Configuration oldConfig = event.getOldValue();
 Set<String> newJars = newConfig.getJarNames();
 Set<String> oldJars = (oldConfig == null) ? new HashSet<>() : oldConfig.getJarNames();

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

@Override
public void afterUpdate(EntryEvent<String, Object> event) {
 ObjectName objectName = null;
 try {
  if (!service.isStartedAndOpen() || !service.isManager()) {
   // NO OP return; No work for Non Manager Nodes
   return;
  }
  objectName = ObjectName.getInstance(event.getKey());
  FederationComponent oldObject = (FederationComponent) event.getOldValue();
  FederationComponent newObject = (FederationComponent) event.getNewValue();
  String className = newObject.getMBeanInterfaceClass();
  Class interfaceClass;
  if (classRef.get(className) != null) {
   interfaceClass = classRef.get(className);
  } else {
   interfaceClass = ClassLoadUtil.classFromName(className);
   classRef.put(className, interfaceClass);
  }
  service.afterUpdateProxy(objectName, interfaceClass, null, newObject, oldObject);
 } catch (Exception e) {
  if (logger.isDebugEnabled()) {
   logger.debug("Aggregation Failed failed for {} with exception {}", e);
  }
 }
}

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

@Override
 public void afterDestroy(EntryEvent event) {
  if (this.sender.isPrimary()) {
   return;
  }
  // fix bug 37603
  // There is a small window where queue has not been created fully yet. The region is created,
  // and it receives afterDestroy callback.

  final Set<RegionQueue> queues = this.sender.getQueues();
  if (queues != null && !queues.isEmpty()) {
   this.sender.getStatistics().decQueueSize();
  }

  // Send event to the event dispatcher
  Object oldValue = event.getOldValue();
  if (oldValue instanceof GatewaySenderEventImpl) {
   GatewaySenderEventImpl senderEvent = (GatewaySenderEventImpl) oldValue;
   if (logger.isDebugEnabled()) {
    logger.debug("Received after Destroy for Secondary event {} the key was {}", senderEvent,
      event.getKey());
   }
   this.processor.handlePrimaryDestroy(senderEvent);
  }
 }
}

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

@Override
 public void afterUpdate(EntryEvent event) {
  System.out.println("UPDATE: " + event.getKey() + " -> (" + event.getOldValue() + " -> "
    + event.getNewValue() + ")");
 }
});

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

assertThat(listenEvent.getTransactionId()).isEqualTo(txId);
assertThat(listenEvent.getKey()).isEqualTo(key);
assertThat(listenEvent.getOldValue()).isEqualTo(oldValue);
assertThat(listenEvent.getNewValue()).isEqualTo(newValue);
assertThat(listenEvent.getCallbackArgument()).isNull();

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

@Override
public void beforeUpdate(EntryEvent<Object, Object> event) throws CacheWriterException {
 if (!event.getRegion().get(event.getKey()).equals(event.getNewValue())) {
  PdxRegistryMismatchException ex = new PdxRegistryMismatchException(
    "Trying to add a PDXType with the same id as an existing PDX type. id="
      + event.getKey() + ", existing pdx type " + event.getOldValue() + ", new type "
      + event.getNewValue());
  throw new CacheWriterException(ex);
 }
}

代码示例来源：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

(DispatchedAndCurrentEvents) HARegionQueue.this.eventsMap.get(key);
Assert.assertTrue(dace != null);
Long expirySequenceID = (Long) event.getOldValue();
boolean expired = dace.expireOrUpdate(expirySequenceID, (ThreadIdentifier) key);
if (isDebugEnabled) {
Conflatable cf = (Conflatable) event.getOldValue();
EventID id = cf.getEventId();
byte[] memID = id.getMembershipID();

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

@Override
public void afterDestroy(EntryEvent<String, HttpSession> event) {
 // A Session expired. If it was destroyed by GemFire expiration, process it.
 // If it was destroyed via Session.invalidate, ignore it since it has
 // already been processed.
 DeltaSessionInterface session = null;
 if (event.getOperation() == Operation.EXPIRE_DESTROY) {
  session = (DeltaSessionInterface) event.getOldValue();
 } else {
  /*
   * This comes into play when we're dealing with an empty client proxy. We need the actual
   * destroyed object to come back from the server so that any associated listeners can fire
   * correctly. Having the destroyed object come back as the callback arg depends on setting the
   * property gemfire.EXPIRE_SENDS_ENTRY_AS_CALLBACK.
   */
  Object callback = event.getCallbackArgument();
  if (callback != null && callback instanceof DeltaSessionInterface) {
   session = (DeltaSessionInterface) callback;
   ManagerBase m = ContextMapper.getContext(session.getContextName());
   if (m != null) {
    session.setOwner(m);
   }
  }
 }
 if (session != null) {
  session.processExpired();
 }
}

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

assertThat(ev.getKey()).isEqualTo("key");
assertThat(ev.getNewValue()).isEqualTo("value3");
assertThat(ev.getOldValue()).isNull();
assertThat(ev.getOperation().isLocalLoad()).isFalse();
assertThat(ev.getOperation().isNetLoad()).isFalse();

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

assertThat(ev.getKey()).isEqualTo("key");
assertThat(ev.getNewValue()).isEqualTo("value2");
assertThat(ev.getOldValue()).isNull();
assertThat(ev.getOperation().isLocalLoad()).isFalse();
assertThat(ev.getOperation().isNetLoad()).isFalse();

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

assertThat(ev.getKey()).isEqualTo("key");
assertThat(ev.getNewValue()).isNull();
assertThat(ev.getOldValue()).isNull();
assertThat(ev.getOperation().isLocalLoad()).isFalse();
assertThat(ev.getOperation().isNetLoad()).isFalse();