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

EntryEvent.getValue介绍

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

代码示例

代码示例来源：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: SonarSource/sonarqube

@Override
public void entryAdded(EntryEvent<ClusterProcess, Boolean> event) {
 if (event.getValue()) {
  listeners.forEach(appStateListener -> appStateListener.onAppStateOperational(event.getKey().getProcessId()));
 }
}

代码示例来源：origin: SonarSource/sonarqube

@Override
public void entryUpdated(EntryEvent<ClusterProcess, Boolean> event) {
 if (event.getValue()) {
  listeners.forEach(appStateListener -> appStateListener.onAppStateOperational(event.getKey().getProcessId()));
 }
}

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

@Override
public void entryAdded(EntryEvent<String, MapSession> event) {
  MapSession session = event.getValue();
  if (session.getId().equals(session.getOriginalId())) {
    if (logger.isDebugEnabled()) {
      logger.debug("Session created with id: " + session.getId());
    }
    this.eventPublisher.publishEvent(new SessionCreatedEvent(this, session));
  }
}

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

public void entryAdded(EntryEvent<String, ChatMessage> event) {
  if (!username.equals(event.getKey())) {
    System.out.println(event.getValue());
  }
}

代码示例来源：origin: com.sitewhere/sitewhere-core

@Override
public void entryUpdated(EntryEvent<String, T> event) {
for (ICacheListener<T> listener : listeners) {
  listener.onEntryUpdated(event.getValue());
}
}

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

@Override
public void entryAdded(EntryEvent<String, V> event)
{
  listenerSupport.notifySet(event.getValue());
}

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

private void handle(EntryEvent<String, List<String>> arg0) throws Exception {
  log.info("'{}' '{}'", arg0.getKey(), arg0.getValue());
  String noun = arg0.getKey();
  List<String> params = arg0.getValue();
  String verb = params.get(0);
  if (verb.equalsIgnoreCase(Constants.COMMAND_VERB_START)) {
    this.handleStart(noun, (params.size() == 1 ? null : params.get(1)));
  } else {
    log.error("Unknown command verb '{}'", verb);
  }
}

代码示例来源：origin: datasalt/splout-db

@Override
public void entryUpdated(EntryEvent<String, DNodeInfo> event) {
 // Update TablespaceVersions
 try {
  mapToDNodeInfo.put(event.getKey(), event.getValue());
  context.getTablespaceState().updateTablespaceVersions(event.getValue(), QNodeHandlerContext.DNodeEvent.UPDATE);
 } catch (TablespaceVersionInfoException e) {
  throw new RuntimeException(e);
 }
}

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

@Override
public void entryAdded(EntryEvent<String, T> event) {
  T entity = event.getValue();
  LOG.trace("Added entity {} to map {}", entity, event.getName());
  listener.onEvent(entity, null, StorageEvent.ADDED);
}

代码示例来源：origin: org.vert-x/vertx-core

@Override
public void entryUpdated(EntryEvent<String, HazelcastServerID> entry) {
 String key = entry.getKey();
 ServerIDs entries = cache.get(key);
 if (entries != null) {
  entries.add(entry.getValue().serverID);
 }
}

代码示例来源：origin: kaazing/gateway

@Override
  public void entryAdded(EntryEvent<String, Collection<String>> event) {
    GL.trace(GL.CLUSTER_LOGGER_NAME, "New entry for balance URI: {}   value: {}", event.getKey(), event.getValue());
  }
}, true);

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

@Override
  public void entryUpdated(EntryEvent<String, Object> event)
  {
    firePut(event.getKey(), event.getValue());
  }
}, true));

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

@Override
  public void entryMerged(EntryEvent<String, Object> event)
  {
    firePut(event.getKey(), event.getValue());
  }
}, true));

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

@Override
public void entryUpdated(EntryEvent<String, String> event) {
  for (MetadataStoreListener listener : this.listeners) {
    listener.onUpdate(event.getKey(), event.getValue());
  }
}

代码示例来源：origin: org.sonarsource.sonarqube/sonar-main

@Override
public void entryAdded(EntryEvent<ClusterProcess, Boolean> event) {
 if (event.getValue()) {
  listeners.forEach(appStateListener -> appStateListener.onAppStateOperational(event.getKey().getProcessId()));
 }
}

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

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

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