Examples of org.infinispan.atomic.Delta

org.infinispan.atomic.Delta
Represents changes made to a {@link DeltaAware} implementation. Implementations should be efficiently{@link java.io.Externalizable} rather than just {@link java.io.Serializable}. @see DeltaAware @author Manik Surtani @since 4.0

      } else {
         notifier.notifyCacheEntryModified(key, entryValue, true, ctx);


         if (value instanceof Delta) {
            // magic
            Delta dv = (Delta) value;
            DeltaAware toMergeWith = null;
            if (entryValue instanceof DeltaAware) toMergeWith = (DeltaAware) entryValue;
            e.setValue(dv.merge(toMergeWith));
            o = entryValue;
            e.setLifespan(lifespanMillis);
            e.setMaxIdle(maxIdleTimeMillis);
         } else {
            o = e.setValue(value);

View Full Code Here

   @TestCachePermission(AuthorizationPermission.WRITE)
   public void testApplyDelta_Object_Delta_ObjectArray(SecureCache<String, String> cache) throws Exception {
      try {
         cache.getTransactionManager().begin();


         cache.applyDelta("deltakey", new Delta() {


            @Override
            public DeltaAware merge(DeltaAware d) {
               return d;
            }

View Full Code Here

               key, entryValue, entryValue == null, true, ctx, this);
      }


      if (value instanceof Delta) {
         // magic
         Delta dv = (Delta) value;
         DeltaAware toMergeWith = null;
         if (entryValue instanceof CopyableDeltaAware) {
            toMergeWith = ((CopyableDeltaAware) entryValue).copy();
         } else if (entryValue instanceof DeltaAware) {
            toMergeWith = (DeltaAware) entryValue;
         }
         e.setValue(dv.merge(toMergeWith));
         o = entryValue;
      } else {
         o = e.setValue(value);
         if (e.isRemoved()) {
            e.setRemoved(false);

View Full Code Here

      } else {
         notifier.notifyCacheEntryModified(key, e.getValue(), true, ctx);


         if (value instanceof Delta) {
            // magic
            Delta dv = (Delta) value;
            Object existing = e.getValue();
            DeltaAware toMergeWith = null;
            if (existing instanceof DeltaAware) toMergeWith = (DeltaAware) existing;
            e.setValue(dv.merge(toMergeWith));
            o = existing;
            e.setLifespan(lifespanMillis);
            e.setMaxIdle(maxIdleTimeMillis);
         } else {
            o = e.setValue(value);

View Full Code Here

   }                                                                        


   public void testPutThrowsLocalException() throws Exception {
      tm(0).begin();


      Delta d = new Delta() {
         public DeltaAware merge(DeltaAware d) {
            throw new RuntimeException("Induced!");
         }
      };

View Full Code Here

   @TestCachePermission(AuthorizationPermission.WRITE)
   public void testApplyDelta_Object_Delta_ObjectArray(SecureCache<String, String> cache) throws Exception {
      try {
         cache.getTransactionManager().begin();


         cache.applyDelta("deltakey", new Delta() {


            @Override
            public DeltaAware merge(DeltaAware d) {
               return d;
            }

View Full Code Here

      notifier.notifyCacheEntryModified(
            key, entryValue, entryValue == null, true, ctx, this);


      if (value instanceof Delta) {
         // magic
         Delta dv = (Delta) value;
         DeltaAware toMergeWith = null;
         if (entryValue instanceof DeltaAware) toMergeWith = (DeltaAware) entryValue;
         e.setValue(dv.merge(toMergeWith));
         o = entryValue;
         e.setMetadata(metadata);
      } else {
         o = e.setValue(value);
         if (e.isRemoved()) {

View Full Code Here

               key, entryValue, entryValue == null, true, ctx, this);
      }


      if (value instanceof Delta) {
         // magic
         Delta dv = (Delta) value;
         DeltaAware toMergeWith = null;
         if (entryValue instanceof CopyableDeltaAware) {
            toMergeWith = ((CopyableDeltaAware) entryValue).copy();
         } else if (entryValue instanceof DeltaAware) {
            toMergeWith = (DeltaAware) entryValue;
         }
         e.setValue(dv.merge(toMergeWith));
         o = entryValue;
         e.setMetadata(metadata);
      } else {
         o = e.setValue(value);
         if (e.isRemoved()) {

View Full Code Here

      notifier.notifyCacheEntryModified(
            key, entryValue, entryValue == null, true, ctx, this);


      if (value instanceof Delta) {
         // magic
         Delta dv = (Delta) value;
         DeltaAware toMergeWith = null;
         if (entryValue instanceof DeltaAware) toMergeWith = (DeltaAware) entryValue;
         e.setValue(dv.merge(toMergeWith));
         o = entryValue;
         e.setMetadata(metadata);
      } else {
         o = e.setValue(value);
         if (e.isRemoved()) {

View Full Code Here

      notifier.notifyCacheEntryModified(
            key, entryValue, entryValue == null, true, ctx, this);


      if (value instanceof Delta) {
         // magic
         Delta dv = (Delta) value;
         DeltaAware toMergeWith = null;
         if (entryValue instanceof DeltaAware) toMergeWith = (DeltaAware) entryValue;
         e.setValue(dv.merge(toMergeWith));
         o = entryValue;
         e.setMetadata(metadata);
      } else {
         o = e.setValue(value);
         if (e.isRemoved()) {

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.infinispan.atomic.Delta

org.infinispan.atomic.impl.AtomicHashMap

org.infinispan.commands.write.PutKeyValueCommand

org.infinispan.security.SecureCacheTestDriver

org.infinispan.tx.exception.ExceptionInCommandTest

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.