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

EntryEvent.getCallbackArgument介绍

暂无

代码示例

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

@Override
public void beforeUpdate(EntryEvent<String, HttpSession> event) throws CacheWriterException {
 this.backingRegion.put(event.getKey(), event.getNewValue(), event.getCallbackArgument());
}

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

@Override
public void beforeCreate(EntryEvent<String, HttpSession> event) throws CacheWriterException {
 this.backingRegion.put(event.getKey(), event.getNewValue(), event.getCallbackArgument());
}

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

String triggerMemberId = (String) event.getCallbackArgument();
if (triggerMemberId == null || newJars.isEmpty()) {
 return;

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

@Override
public void afterDestroy(EntryEvent<String, GatewayDelta> event) {
 // If the event is from the local site, create a 'destroy' event and send it to the
 // gateway delta region
 if (event.getCallbackArgument() != null) {
  if (this.cache.getLogger().fineEnabled()) {
   StringBuilder builder = new StringBuilder();
   builder.append("GatewayDeltaForwarderCacheListener: Received destroy event for ")
     .append(event.getKey()).append("->").append(event.getNewValue())
     .append(" that originated in the local site. Sending it to the remote site.");
   this.cache.getLogger().fine(builder.toString());
  }
  // Distribute the destroy event to the gateway hub(s)
  String sessionId = event.getKey();
  getGatewayDeltaRegion().put(sessionId,
    new GatewayDeltaDestroyEvent(event.getRegion().getFullPath(), sessionId));
 } else {
  if (this.cache.getLogger().fineEnabled()) {
   StringBuilder builder = new StringBuilder();
   builder.append("GatewayDeltaForwarderCacheListener: Received destroy event for session ")
     .append(event.getKey())
     .append(" that either expired or originated in the remote site.");
   this.cache.getLogger().fine(builder.toString());
  }
 }
}

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

@Override
public void afterUpdate(EntryEvent<String, GatewayDelta> event) {
 // If the event is from the local site, create an 'update' event and send it to the
 // gateway delta region
 if (event.getCallbackArgument() == null) {
  if (this.cache.getLogger().fineEnabled()) {
   StringBuilder builder = new StringBuilder();
   builder.append("GatewayDeltaForwarderCacheListener: Received update event for ")
     .append(event.getKey()).append("->").append(event.getNewValue())
     .append(" that originated in the local site. Sending it to the remote site.");
   this.cache.getLogger().fine(builder.toString());
  }
  // Distribute the update event to the gateway hub(s)
  GatewayDelta session = event.getNewValue();
  getGatewayDeltaRegion().put(event.getKey(), session.getCurrentGatewayDeltaEvent());
  // Reset the current delta
  session.setCurrentGatewayDeltaEvent(null);
 } else {
  if (this.cache.getLogger().fineEnabled()) {
   StringBuilder builder = new StringBuilder();
   builder.append("GatewayDeltaForwarderCacheListener: Received update event for ")
     .append(event.getKey()).append("->").append(event.getNewValue())
     .append(" that originated in the remote site.");
   this.cache.getLogger().fine(builder.toString());
  }
 }
}

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

assertThat(listenEvent.getOldValue()).isEqualTo(oldValue);
assertThat(listenEvent.getNewValue()).isEqualTo(newValue);
assertThat(listenEvent.getCallbackArgument()).isNull();
assertThat(listenEvent.isCallbackArgumentAvailable()).isTrue();
assertThat(listenEvent.getOperation().isLoad()).isFalse();

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

if (event.getCallbackArgument() == null) {
 if (this.cache.getLogger().fineEnabled()) {
  StringBuilder builder = new StringBuilder();

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

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().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();

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

assertThat(ev.getOperation().isLoad()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isLoad()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
 assertThat(ev.getOperation().isLoad()).isFalse();
 assertThat(ev.getOperation().isNetSearch()).isFalse();
 assertThat(ev.getCallbackArgument()).isNull();
 assertThat(ev.isCallbackArgumentAvailable()).isTrue();
 assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isLoad()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isFalse();
assertThat(ev.getOperation().isLoad()).isFalse();
assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).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();
 }
}

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

assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isTrue();

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

assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isTrue();

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

assertThat(ev.getOperation().isNetSearch()).isFalse();
assertThat(ev.getOperation().isExpiration()).isFalse();
assertThat(ev.getCallbackArgument()).isNull();
assertThat(ev.isCallbackArgumentAvailable()).isTrue();
assertThat(ev.isOriginRemote()).isTrue();

代码示例来源：origin: org.apache.geode/geode-modules

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: org.apache.geode/geode-modules

public void beforeUpdate(EntryEvent<String, HttpSession> event) throws CacheWriterException {
 this.backingRegion.put(event.getKey(), event.getNewValue(), event.getCallbackArgument());
}

代码示例来源：origin: org.apache.geode/geode-modules

public void beforeCreate(EntryEvent<String, HttpSession> event) throws CacheWriterException {
 this.backingRegion.put(event.getKey(), event.getNewValue(), event.getCallbackArgument());
}

代码示例来源：origin: org.apache.geode/geode-modules

public void afterDestroy(EntryEvent<String, GatewayDelta> event) {
 // If the event is from the local site, create a 'destroy' event and send it to the
 // gateway delta region
 if (event.getCallbackArgument() != null) {
  if (this.cache.getLogger().fineEnabled()) {
   StringBuilder builder = new StringBuilder();
   builder.append("GatewayDeltaForwarderCacheListener: Received destroy event for ")
     .append(event.getKey()).append("->").append(event.getNewValue())
     .append(" that originated in the local site. Sending it to the remote site.");
   this.cache.getLogger().fine(builder.toString());
  }
  // Distribute the destroy event to the gateway hub(s)
  String sessionId = event.getKey();
  getGatewayDeltaRegion().put(sessionId,
    new GatewayDeltaDestroyEvent(event.getRegion().getFullPath(), sessionId));
 } else {
  if (this.cache.getLogger().fineEnabled()) {
   StringBuilder builder = new StringBuilder();
   builder.append("GatewayDeltaForwarderCacheListener: Received destroy event for session ")
     .append(event.getKey())
     .append(" that either expired or originated in the remote site.");
   this.cache.getLogger().fine(builder.toString());
  }
 }
}