import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
/**
 * Listens to Infinispan cache entry create and cache entry modify events. Converts data into JPG image and stores
 * it into dedicated cache. Then classifies the image using trained TenforFlow NN and store the results into the
 * result cache.
 * 
 * @param e
 *            Custom event from StringByteArrayConverter, containing String key and byte array value.
 */
@ClientCacheEntryCreated
@ClientCacheEntryModified
public void onCacheEvent(ClientCacheEntryCustomEvent<byte[]> e) {
    ByteBuffer buffer = ByteBuffer.wrap(e.getEventData());
    int keyLength = UnsignedNumeric.readUnsignedInt(buffer);
    byte[] keyBytes = new byte[keyLength];
    buffer.get(keyBytes);
    String key = new String(keyBytes);
    int valueLength = UnsignedNumeric.readUnsignedInt(buffer);
    byte valueBytes[] = new byte[valueLength];
    buffer.get(valueBytes);
    // as JS client currently doesn't support converters, we cannot send JPG image as part of the client event, thus
    // storing it into separate (eagerly evicted) cache
    jpgCache.put(key, bufferAsJpgString(valueBytes));

    String result = classifier.processEvent(valueBytes);
    resultCache.put(key, result);
    System.out.printf("On the image with ID %s could be number %s\n", key, result);
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
public void entryCreated(ClientCacheEntryCreatedEvent<String> event) {
    if (logger.isDebugEnabled()) {
        logger.debug("Session created with id: " + event.getKey());
    }
    eventPublisher.publishEvent(new SessionCreatedEvent(this, event.getKey()));
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
@ClientCacheEntryModified
@ClientCacheEntryRemoved
@ClientCacheEntryExpired
@ClientCacheFailover
public void processClientEvent(ClientEvent event) {
    if (isAccepted(event.getType().toString())) {
        infinispanConsumer.processEvent(event.getType().toString(), false, cacheName, getKey(event), getEventData(event));
    }
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
public void entryCreated(ClientCacheEntryCreatedEvent<String> event) {
	log.info(String.format(EVENT_MSG_FORMAT, "Created", event.getKey()));
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
public void entryCreated(ClientCacheEntryCreatedEvent event) {

    creationsInTheLastInterval.incrementAndGet();
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
public void processEvent(ClientCacheEntryCreatedEvent<Object> event) {
    logger.trace("Received ClientEvent [{}]", event);
    dispatch(event.getType().toString(), false, cacheName, event.getKey());
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
public void entryCreated(ClientCacheEntryCreatedEvent<String> event) {
   System.out.printf("Created %s%n", event.getKey());
}
 

import org.infinispan.client.hotrod.annotation.ClientCacheEntryCreated; //导入依赖的package包/类
@ClientCacheEntryCreated
public void entryCreated(ClientCacheEntryCreatedEvent event) {

    //Console.info("" + event);
    System.out.println("ClientCacheEntryCreated");

}