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

EntryEvent.getKey介绍

暂无

代码示例

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

@Override
public Object getSubstituteValue(EntryEvent event) {
 this.numInvocations.incrementAndGet();
 return SUBSTITUTION_PREFIX + event.getKey();
}

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

@Override
public void afterInvalidate2(EntryEvent event) {
 Object key = event.getKey();
 // logger.fine("got invalidate for " + key);
 this.invalidates.add(key);
}

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

@Override
 public void afterUpdate(final EntryEvent event) {
  beforeWrite.accept(event.getKey());
 }
});

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

@Override
public Object getSubstituteValue(EntryEvent event) {
 return new GatewayEventSubstituteObject(this, SUBSTITUTION_PREFIX + event.getKey());
}

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

@Override
public void beforeDestroy(EntryEvent<String, HttpSession> event) throws CacheWriterException {
 try {
  this.backingRegion.destroy(event.getKey(), event.getCallbackArgument());
 } catch (EntryNotFoundException e) {
  // I think it is safe to ignore this exception. The entry could have
  // expired already in the backing region.
 }
}

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

public EventWrapper(EntryEvent ee, int type) {
 this.event = ee;
 this.key = ee.getKey();
 this.val = ee.getNewValue();
 this.arg = ee.getCallbackArgument();
 this.type = type;
}

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

private void log(EntryEvent event) {
 StringBuilder builder = new StringBuilder();
 builder.append("DebugCacheListener: Received ").append(event.getOperation()).append(" for key=")
   .append(event.getKey());
 if (event.getNewValue() != null) {
  builder.append("; value=").append(event.getNewValue());
 }
 event.getRegion().getCache().getLogger().info(builder.toString());
}

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

@Override
public void beforeCreate(EntryEvent<Object, Object> event) throws CacheWriterException {
 Object newValue = event.getNewValue();
 if (newValue instanceof PdxType) {
  logger.info("Adding new type: {}", ((PdxType) event.getNewValue()).toFormattedString());
 } else {
  logger.info("Adding new type: {} {}", event.getKey(),
    ((EnumInfo) newValue).toFormattedString());
 }
}

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

@Override
 public void beforeCreate(EntryEvent event) throws CacheWriterException {
  System.out.println("key: " + event.getKey());
  System.out.println("value: " + event.getNewValue());
  hasResult = true;
 }
}

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

@Override
public void afterDestroy(EntryEvent event) {
 logger.debug("BucketListener: o={}, r={}, k={}, dm={}", event.getOperation(),
   event.getRegion().getFullPath(), event.getKey(), event.getDistributedMember());
}

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

@Override
public void afterInvalidate(EntryEvent event) {
 logger.debug("BucketListener: o={}, r={}, k={}, dm={}", event.getOperation(),
   event.getRegion().getFullPath(), event.getKey(), event.getDistributedMember());
}

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

@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 afterCreate(EntryEvent event) {
 EntryEventImpl ee = (EntryEventImpl) event;
 logger.debug("BucketListener: o={}, r={}, k={}, nv={}, dm={}", event.getOperation(),
   event.getRegion().getFullPath(), event.getKey(), ee.getRawNewValue(),
   event.getDistributedMember());
}

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

@Override
public void afterUpdate(EntryEvent event) {
 EntryEventImpl ee = (EntryEventImpl) event;
 logger.debug("BucketListener: o={}, r={}, k={}, ov={}, nv={}, dm={}", event.getOperation(),
   event.getRegion().getFullPath(), event.getKey(), ee.getRawOldValue(),
   ee.getRawNewValue(), event.getDistributedMember());
}

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

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

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

@Override
 public void afterCreate(EntryEvent event) {
  if ((Long) event.getKey() == 900) {
   cache.getLogger().fine(" Gateway sender is killed by a test");
   cache.close();
   cache.getDistributedSystem().disconnect();
  }
 }
};

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

private void writeEvent(EntryEvent<K, V> event) {
 if (eventCanBeIgnored(event.getOperation())) {
  return;
 }
 checkInitialized((InternalCache) event.getRegion().getRegionService());
 totalEvents.add(1);
 try {
  getSqlHandler().write(event.getRegion(), event.getOperation(), event.getKey(),
    getPdxNewValue(event));
 } catch (SQLException e) {
  throw JdbcConnectorException.createException(e);
 }
}