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

EntryEvent.getOldValue介绍

[英]Returns the old value of the entry event.
[中]返回条目事件的旧值。

代码示例

代码示例来源：origin: spring-projects/spring-session

@Override
public void entryEvicted(EntryEvent<String, MapSession> event) {
  if (logger.isDebugEnabled()) {
    logger.debug("Session expired with id: " + event.getOldValue().getId());
  }
  this.eventPublisher
      .publishEvent(new SessionExpiredEvent(this, event.getOldValue()));
}

代码示例来源：origin: spring-projects/spring-session

@Override
public void entryRemoved(EntryEvent<String, MapSession> event) {
  MapSession session = event.getOldValue();
  if (session != null) {
    if (logger.isDebugEnabled()) {
      logger.debug("Session deleted with id: " + session.getId());
    }
    this.eventPublisher.publishEvent(new SessionDeletedEvent(this, session));
  }
}

代码示例来源：origin: codecentric/spring-boot-admin

@Override
  public void entryUpdated(EntryEvent<InstanceId, List<InstanceEvent>> event) {
    log.debug("Updated {}", event);
    long lastKnownVersion = getLastVersion(event.getOldValue());
    List<InstanceEvent> newEvents = event.getValue()
                       .stream()
                       .filter(e -> e.getVersion() > lastKnownVersion)
                       .collect(Collectors.toList());
    HazelcastEventStore.this.publish(newEvents);
  }
}, true);

代码示例来源：origin: com.atlassian.cache/atlassian-cache-hazelcast

@Override
  public void entryEvicted(EntryEvent<String, V> event)
  {
    listenerSupport.notifyEvict(event.getOldValue());
  }
}

代码示例来源：origin: com.atlassian.cache/atlassian-cache-hazelcast

@Override
public void entryRemoved(EntryEvent<String, V> event)
{
  listenerSupport.notifyReset(event.getOldValue());
}

代码示例来源：origin: org.springframework.session/spring-session-hazelcast

@Override
public void entryEvicted(EntryEvent<String, MapSession> event) {
  if (logger.isDebugEnabled()) {
    logger.debug("Session expired with id: " + event.getOldValue().getId());
  }
  this.eventPublisher
      .publishEvent(new SessionExpiredEvent(this, event.getOldValue()));
}

代码示例来源：origin: org.springframework.session/spring-session-hazelcast

@Override
public void entryRemoved(EntryEvent<String, MapSession> event) {
  MapSession session = event.getOldValue();
  if (session != null) {
    if (logger.isDebugEnabled()) {
      logger.debug("Session deleted with id: " + session.getId());
    }
    this.eventPublisher.publishEvent(new SessionDeletedEvent(this, session));
  }
}

代码示例来源：origin: org.meridor.perspective/perspective-backend-common

@Override
public void entryRemoved(EntryEvent<String, T> event) {
  T oldEntity = event.getOldValue();
  LOG.trace("Deleted entry {} from map {}", oldEntity, event.getName());
  listener.onEvent(null, oldEntity, StorageEvent.DELETED);
}

代码示例来源：origin: com.atlassian.cache/atlassian-cache-hazelcast

@Override
public void entryRemoved(EntryEvent<K, V> event)
{
  listenerSupport.notifyRemove(event.getKey(), event.getOldValue());
}

代码示例来源：origin: spring-projects/spring-integration-extensions

@Override
public void entryRemoved(EntryEvent<String, String> event) {
  for (MetadataStoreListener listener : this.listeners) {
    listener.onRemove(event.getKey(), event.getOldValue());
  }
}

代码示例来源：origin: com.atlassian.cache/atlassian-cache-hazelcast

@Override
  public void entryEvicted(EntryEvent<K, V> event)
  {
    listenerSupport.notifyEvict(event.getKey(), event.getOldValue());
  }
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public void entryEvicted(EntryEvent<DocumentKey, Document> event) {
  evictDocument(event.getKey(), event.getOldValue());
}

代码示例来源：origin: org.meridor.perspective/perspective-backend-common

@Override
public void entryUpdated(EntryEvent<String, T> event) {
  T entity = event.getValue();
  T oldEntity = event.getOldValue();
  LOG.trace("Modified entity {} in map {}", entity, event.getName());
  listener.onEvent(entity, oldEntity, StorageEvent.MODIFIED);
}

代码示例来源：origin: kloiasoft/eventapis

@Override
public void entryExpired(EntryEvent<String, Topology> event) {
  event.getKey();
  Topology topology = event.getOldValue();
  try {
    topology.getProducedEvents().forEach(this::setLeafs);
  } catch (Exception ex) {
    log.warn("Error while trying to check Leafs:" + ex.getMessage());
  }
  if (!topology.isFinished()) {
    log.warn("Topology Doesn't Finished:" + topology.toString());
    operationsHistoryMap.putIfAbsent(event.getKey(), event.getOldValue(), 1, TimeUnit.DAYS);
  } else {
    log.info("Topology OK:" + topology.toString());
    operationsHistoryMap.putIfAbsent(event.getKey(), event.getOldValue(), 1, TimeUnit.HOURS);
  }
}

代码示例来源：origin: com.atlassian.cache/atlassian-cache-hazelcast

@Override
public void entryUpdated(EntryEvent<K, V> event)
{
  listenerSupport.notifyUpdate(event.getKey(), event.getValue(), event.getOldValue());
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
  public String toString() {
    return "EntryEvent{"
        + super.toString()
        + ", key=" + getKey()
        + ", oldValue=" + getOldValue()
        + ", value=" + getValue()
        + ", mergingValue=" + getMergingValue()
        + '}';
  }
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
  public String toString() {
    return "EntryEvent{"
        + super.toString()
        + ", key=" + getKey()
        + ", oldValue=" + getOldValue()
        + ", value=" + getValue()
        + ", mergingValue=" + getMergingValue()
        + '}';
  }
}

代码示例来源：origin: gudaoxuri/dew

private void packageEntryEvent(Consumer<EntryEvent<M>> fun, com.hazelcast.core.EntryEvent<String, M> entryEvent) {
  EntryEvent<M> ee = new EntryEvent<>();
  ee.setKey(entryEvent.getKey());
  ee.setOldValue(entryEvent.getOldValue());
  ee.setValue(entryEvent.getValue());
  fun.accept(ee);
}

代码示例来源：origin: aillamsun/devX

private void packageEntryEvent(Consumer<EntryEvent<M>> fun, com.hazelcast.core.EntryEvent<String, M> entryEvent) {
  EntryEvent<M> ee = new EntryEvent<>();
  ee.setKey(entryEvent.getKey());
  ee.setOldValue(entryEvent.getOldValue());
  ee.setValue(entryEvent.getValue());
  fun.accept(ee);
}

代码示例来源：origin: spring-projects/spring-integration-extensions

@Override
@SuppressWarnings("unchecked")
protected Message<?> toMessage(AbstractIMapEvent event) {
  final Map<String, Object> headers = new HashMap<String, Object>();
  headers.put(HazelcastHeaders.EVENT_TYPE, event.getEventType().name());
  headers.put(HazelcastHeaders.MEMBER, event.getMember().getSocketAddress());
  headers.put(HazelcastHeaders.CACHE_NAME, event.getName());
  if (event instanceof EntryEvent) {
    EntryEvent<K, V> entryEvent = (EntryEvent<K, V>) event;
    EntryEventMessagePayload<K, V> messagePayload = new EntryEventMessagePayload<>(entryEvent.getKey(),
        entryEvent.getValue(), entryEvent.getOldValue());
    return getMessageBuilderFactory().withPayload(messagePayload).copyHeaders(headers).build();
  }
  else if (event instanceof MapEvent) {
    return getMessageBuilderFactory()
        .withPayload(((MapEvent) event).getNumberOfEntriesAffected()).copyHeaders(headers).build();
  }
  else {
    throw new IllegalStateException("Invalid event is received. Event : " + event);
  }
}