CrossCacheEntryProcessor

CrossCacheEntryProcessor.java

@SuppressWarnings("serial")
public class CrossCacheEntryProcessor implements EntryProcessor, PortableObject {

	// the cache to be accessed
	private String crossCache;
	private static Log LOGGER = LogFactory.getLog(CrossCacheEntryProcessor.class);

	// required for POF
	public CrossCacheEntryProcessor() {
	}

	/**
	 * Creates a new cross cache entry processor by passing the name of the cache to
	 * access via direct backing map access
	 * 
	 * @param crossCache
	 */
	public CrossCacheEntryProcessor(String crossCache) {
		this.crossCache = crossCache;
	}

	@SuppressWarnings("unused")
	@Override
	public Object process(Entry entry) {
		LOGGER.debug("entry processor starting");

		BackingMapManagerContext mctx = ((BinaryEntry) entry).getContext();
		BackingMapContext ctx = mctx.getBackingMapContext(crossCache);

		BinaryEntry otherEntry = (BinaryEntry) ctx.getBackingMapEntry(mctx.getKeyToInternalConverter().convert(1));

		LOGGER.debug("Entry processor ended");
		return null;
	}

	@Override
	@SuppressWarnings("rawtypes")
	public Map processAll(Set set) {
		for (Object object : set) {
			@SuppressWarnings("unused")
			Entry e = (Entry) object;
		}
		return null;
	}

	@Override
	public void readExternal(PofReader reader) throws IOException {

		crossCache = reader.readString(0);
	}

	@Override
	public void writeExternal(PofWriter writer) throws IOException {

		writer.writeString(0, crossCache);
	}

}