import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void entryRemoved(CacheEntryRemovedEvent<String, ExpiringSession> event) {
    if (logger.isDebugEnabled()) {
        logger.debug("Session expired with id: " + event.getOldValue().getId());
    }
    eventPublisher.publishEvent(new SessionDeletedEvent(this, event.getOldValue()));
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void entryRemoved(CacheEntryRemovedEvent<MultiMapKey, Object> event) {
  MultiMapKey multiMapKey = event.getKey();
  K k = DataConverter.fromCachedObject(multiMapKey.getKey());
  V v = DataConverter.fromCachedObject(multiMapKey.getValue());
  ChoosableSet<V> entries = nearCache.get(k);
  if (entries != null) {
    entries.remove(v);
    if (entries.isEmpty()) {
      nearCache.remove(k);
    }
  }
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryModified
@CacheEntryRemoved
@CacheEntryExpired
public void processEvent(CacheEntryEvent<Object, Object> event) {
    if (isAccepted(event.getType().toString())) {
        infinispanConsumer.processEvent(event.getType().toString(), IS_PRE, event.getCache().getName(), event.getKey());
    }
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryActivated
@CacheEntryCreated
@CacheEntryInvalidated
@CacheEntryLoaded
@CacheEntryModified
@CacheEntryPassivated
@CacheEntryRemoved
@CacheEntryVisited
@CacheEntryExpired
public void processEvent(CacheEntryEvent<Object, Object> event) {
    dispatch(event.getType().toString(), event.isPre(), event.getCache().getName(), event.getKey());
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryModified
@CacheEntryRemoved
@CacheEntryExpired
public void processEvent(CacheEntryEvent<Object, Object> event) {
    if (isAccepted(event.getType().toString())) {
        infinispanConsumer.processEvent(event.getType().toString(), event.isPre(), event.getCache().getName(), event.getKey());
    }
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void removed(CacheEntryRemovedEvent<String, Property<?>> event) {
    if (event.isPre()) {
        return;
    }

    List<Observer> observers = this.observersMap.get(event.getKey());
    if (observers != null && event.getOldValue() != null) {
        observers.forEach(observer -> observer.removed(event.getValue()));
    }
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryCreated
@CacheEntryRemoved
@CacheEntryModified
public void handleCacheEntry(CacheEntryEvent<String, Message<V>> cacheEvent) {
	if (cacheEvent instanceof CacheEntryCreatedEvent) {
		onMessage(cacheEvent.getValue());
	} else if (cacheEvent instanceof CacheEntryModifiedEvent) {
		onMessage(cacheEvent.getValue());
	}
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void dataRemoved(CacheEntryRemovedEvent event) {
	if (log.isTraceEnabled()) {
		if (event.isPre()) {
			log.trace("Going to remove entry " + event.getKey() + " from the cache " + event.getCache().getName());
		} else {
			log.trace("Removed entry " + event.getKey() + " from the cache " + event.getCache().getName());
		}
	}
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void observeRemove(CacheEntryRemovedEvent<Object, Object> event) {
    if (event.isPre()) {
        return;
    }

    if (this.toBeUpdated != null) {
        this.toBeUpdated.entryDeleted(event.getKey(), this.containerName,
                this.cacheName, event.isOriginLocal());
    }
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void removed(CacheEntryRemovedEvent<Long, XOffering> event) {
	if (event.isPre())
		removeCourses(event.getValue());
}
 

import org.infinispan.notifications.cachelistener.annotation.CacheEntryRemoved; //导入依赖的package包/类
@CacheEntryRemoved
public void sessionEvicted(CacheEntryRemovedEvent event) {
    log.info("Session with id {} evicted ", event.getKey());
}