Examples of GridDrReceiverCacheConflictResolverMode

org.gridgain.grid.dr.cache.receiver.GridDrReceiverCacheConflictResolverMode

Examples of org.gridgain.grid.dr.cache.receiver.GridDrReceiverCacheConflictResolverMode

     */
    public boolean drNeedResolve(GridCacheVersion oldVer, GridCacheVersion newVer) {
        GridDrReceiverCacheConfiguration drRcvCfg = cacheCfg.getDrReceiverConfiguration();


        if (drRcvCfg != null) {
            GridDrReceiverCacheConflictResolverMode mode = drRcvCfg.getConflictResolverMode();


            assert mode != null;


            return oldVer.dataCenterId() != dataCenterId || newVer.dataCenterId() != dataCenterId || mode == DR_ALWAYS;
        }

View Full Code Here

Examples of org.gridgain.grid.dr.cache.receiver.GridDrReceiverCacheConflictResolverMode

        GridDrEntry<K, V> newEntry) throws GridException {
        GridDrReceiverCacheConfiguration drRcvCfg = cacheCfg.getDrReceiverConfiguration();


        assert drRcvCfg != null;


        GridDrReceiverCacheConflictResolverMode mode = drRcvCfg.getConflictResolverMode();


        assert mode != null;


        GridDrReceiverConflictContextImpl<K, V> ctx = new GridDrReceiverConflictContextImpl<>(oldEntry, newEntry);

View Full Code Here

Examples of org.gridgain.grid.dr.cache.receiver.GridDrReceiverCacheConflictResolverMode


            if (mongoCache)
                throw new GridException("Mongo cache cannot be data center replication receiver cache: " +
                    cc.getName());


            GridDrReceiverCacheConflictResolverMode rslvrMode = drRcvCfg.getConflictResolverMode();


            assertParameter(rslvrMode != null, "cfg.getDrReceiverConfiguration().getConflictResolverPolicy() != null");


            if (rslvrMode != DR_AUTO && drRcvCfg.getConflictResolver() == null)
                throw new GridException("Conflict resolver must be not null with " + rslvrMode + " resolving policy");

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.