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

EntryEvent.getOperation介绍

暂无

代码示例

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

/**
 * Selects the entry events whose operation matches the given predicate.
 *
 * @param cacheEvents the cache events from which to select entry events
 * @param operationPredicate tests each event's operation to determine whether to include the
 *        event
 * @return list of entry events whose operations match the given predicate
 * @throws ClassCastException if the predicate matches the operation of an event that is not an
 *         {@code EntryEvent}
 */
public static <K, V> List<EntryEvent<K, V>> getEntryEventsWithOperation(
  List<CacheEvent<K, V>> cacheEvents,
  Predicate<Operation> operationPredicate) {
 return getEntryEventsMatching(cacheEvents, e -> operationPredicate.test(e.getOperation()));
}

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

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 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 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

assertThat(listenEvent.getCallbackArgument()).isNull();
assertThat(listenEvent.isCallbackArgumentAvailable()).isTrue();
assertThat(listenEvent.getOperation().isLoad()).isFalse();
assertThat(listenEvent.getOperation().isNetLoad()).isFalse();
assertThat(listenEvent.getOperation().isNetSearch()).isFalse();
assertThat(listenEvent.getOperation().isLocalLoad()).isFalse();
assertThat(listenEvent.getOperation().isDistributed()).isTrue();
assertThat(listenEvent.getOperation().isExpiration()).isFalse();
assertThat(listenEvent.isOriginRemote()).isTrue();
cdcl.setEntryEvent(null);

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

@Test
public void beforeCreateWithLoadEventDoesNothing() throws Exception {
 when(entryEvent.getOperation()).thenReturn(Operation.LOCAL_LOAD_CREATE);
 writer.beforeCreate(entryEvent);
 verify(sqlHandler, times(0)).write(any(), any(), any(), any());
 assertThat(writer.getTotalEvents()).isEqualTo(0);
}

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

@Test
public void beforeDestroyWithDestroyEventWritesToSqlHandler() throws Exception {
 when(entryEvent.getOperation()).thenReturn(Operation.DESTROY);
 when(entryEvent.getSerializedNewValue()).thenReturn(null);
 writer.beforeDestroy(entryEvent);
 verify(sqlHandler, times(1)).write(eq(region), eq(Operation.DESTROY), eq(key), eq(null));
}

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

Operation op = event.getOperation();
for (Iterator it = foi.entrySet().iterator(); it.hasNext();) {
 Map.Entry entry = (Map.Entry) it.next();

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

protected void razeDynamicRegion(EntryEvent event) {
 if (!DynamicRegionFactory.this.isOpen())
  return;
 // Because CacheClientUpdater calls localDestroy we need to allow
 // "local" events. If this is a true local then c.getRegion will return
 // null and this code will do nothing.
 // When bug 35644 fixed the following "if" can be uncommented.
 // Ignore the callback if it originated in this process (because the region
 // will already have been destroyed)
 String fullRegionName = (String) event.getKey();
 Region drRegion = cache.getRegion(fullRegionName);
 if (drRegion != null) {
  try {
   doBeforeRegionDestroyed(drRegion, true, event.getOperation().isDistributed(),
     event.getOperation().isExpiration(), event.getDistributedMember());
   drRegion.localDestroyRegion();
   doAfterRegionDestroyed(drRegion, true, event.getOperation().isDistributed(),
     event.getOperation().isExpiration(), event.getDistributedMember());
  } catch (Exception e) {
   cache.getLogger().warning(
     String.format("Error attempting to locally destroy Dynamic Region: %s",
       fullRegionName),
     e);
  }
 }
}

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

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

@Before
public void setUp() {
 entryEvent = mock(EntryEvent.class);
 pdxInstance = mock(PdxInstance.class);
 sqlHandler = mock(SqlHandler.class);
 region = mock(InternalRegion.class);
 serializedNewValue = mock(SerializedCacheValue.class);
 regionEvent = mock(RegionEvent.class);
 cache = Fakes.cache();
 key = "key";
 when(entryEvent.getRegion()).thenReturn(region);
 when(entryEvent.getKey()).thenReturn(key);
 when(entryEvent.getRegion().getRegionService()).thenReturn(cache);
 when(entryEvent.getSerializedNewValue()).thenReturn(serializedNewValue);
 when(entryEvent.getOperation()).thenReturn(Operation.CREATE);
 when(serializedNewValue.getDeserializedValue()).thenReturn(pdxInstance);
 writer = new JdbcWriter<>(sqlHandler, cache);
}

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

assertThat(ev.getNewValue()).isEqualTo("txValue");
assertThat(ev.getOldValue()).isNull();
assertThat(ev.getOperation().isLocalLoad()).isFalse();
assertThat(ev.getOperation().isNetLoad()).isFalse();
assertThat(ev.getOperation().isLoad()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getNewValue()).isEqualTo("txValue3");
assertThat(ev.getOldValue()).isNull();
assertThat(ev.getOperation().isLocalLoad()).isFalse();
assertThat(ev.getOperation().isNetLoad()).isFalse();
assertThat(ev.getOperation().isLoad()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isDistributed()).isTrue();
assertThat(ev.getNewValue()).isEqualTo("new txValue");
assertThat(ev.getOldValue()).isNull();
assertThat(ev.getOperation().isLocalLoad()).isFalse();
assertThat(ev.getOperation().isNetLoad()).isFalse();
assertThat(ev.getOperation().isLoad()).isFalse();

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