assertEquals(op.getValue(), cache1.get(key));
}
private void blockEntryCommit(final CheckPoint checkPoint, AdvancedCache<Object, Object> cache) {
ClusteringDependentLogic cdl1 = cache.getComponentRegistry().getComponent(ClusteringDependentLogic.class);
ClusteringDependentLogic replaceCdl = new ClusteringDependentLogicDelegator(cdl1) {
@Override
public void commitEntry(CacheEntry entry, Metadata metadata, FlagAffectedCommand command,
InvocationContext ctx, Flag trackFlag, boolean l1Invalidation) {
final Address source = ctx.getOrigin();
CacheEntry newEntry = new CacheEntryDelegator(entry) {