Examples of org.infinispan.distribution.MagicKey

org.infinispan.distribution.MagicKey
A special type of key that if passed a cache in its constructor, will ensure it will always be assigned to that cache (plus however many additional caches in the hash space). Note that this only works if all the caches have joined a single cluster before creating the key. If the cluster membership changes then the keys may move to other servers.

      Cache<Object, String> cache2 = cache(2, CACHE_NAME);


      ClusterListener clusterListener = listener();
      cache0.addListener(clusterListener);


      MagicKey key = new MagicKey(cache1, cache0);


      verifySimpleInsertion(cache2, key, FIRST_VALUE, null, clusterListener, FIRST_VALUE);
   }

View Full Code Here

      Cache<Object, String> cache0 = cache(0, CACHE_NAME);


      ClusterListener clusterListener = listener();
      cache0.addListener(clusterListener);


      MagicKey key = new MagicKey(cache0);


      verifySimpleInsertion(cache0, key, FIRST_VALUE, null, clusterListener, FIRST_VALUE);
   }

View Full Code Here

      Cache<Object, String> cache2 = cache(2, CACHE_NAME);


      ClusterListener clusterListener = listener();
      cache0.addListener(clusterListener);


      MagicKey key = new MagicKey(cache1, cache2);


      verifySimpleInsertion(cache0, key, FIRST_VALUE, null, clusterListener, FIRST_VALUE);
   }

View Full Code Here

      verifySimpleInsertion(cache0, key, FIRST_VALUE, null, clusterListener, FIRST_VALUE);
   }


   @Test
   public void testSimpleFilterNotOwner() {
      testSimpleFilter(new MagicKey(cache(1, CACHE_NAME), cache(2, CACHE_NAME)));
   }

View Full Code Here

      testSimpleFilter(new MagicKey(cache(1, CACHE_NAME), cache(2, CACHE_NAME)));
   }


   @Test
   public void testSimpleFilterLocalOnly() {
      testSimpleFilter(new MagicKey(cache(0, CACHE_NAME)));
   }

View Full Code Here

   }


   @Test
   public void testMetadataFilterNotOwner() {
      final String keyToFilterOut = "filter-me";
      testFilter(keyToFilterOut, new MagicKey(cache(1, CACHE_NAME), cache(2, CACHE_NAME)), 1000l, new LifespanFilter<Object, String>(100));
   }

View Full Code Here

   }


   @Test
   public void testMetadataFilterLocalOnly() {
      final String keyToFilterOut = "filter-me";
      testFilter(keyToFilterOut, new MagicKey(cache(0, CACHE_NAME)), 1000l, new LifespanFilter<Object, String>(100));
   }

View Full Code Here

      verifySimpleInsertion(cache0, keyToUse, FIRST_VALUE, lifespan, clusterListener, FIRST_VALUE);
   }


   @Test
   public void testSimpleConverterNotOwner() {
      testSimpleConverter(new MagicKey(cache(1, CACHE_NAME), cache(2, CACHE_NAME)));
   }

View Full Code Here

      testSimpleConverter(new MagicKey(cache(1, CACHE_NAME), cache(2, CACHE_NAME)));
   }


   @Test
   public void testSimpleConverterLocalOnly() {
      testSimpleConverter(new MagicKey(cache(0, CACHE_NAME)));
   }

View Full Code Here


   @Test
   public void testMetadataConverterSuccessNotOwner() {
      long lifespan = 25000;
      LifespanConverter converter = new LifespanConverter(true, 500);
      testConverter(new MagicKey(cache(1, CACHE_NAME), cache(2, CACHE_NAME)), FIRST_VALUE, lifespan, lifespan, converter);
   }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.infinispan.distribution.MagicKey

org.infinispan.api.AbstractRepeatableReadIsolationTest

org.infinispan.api.ConditionalOperationPrimaryOwnerFailTest

org.infinispan.api.ConditionalOperationsConcurrentWriteSkewTest

org.infinispan.api.flags.FlagsEnabledTest

org.infinispan.api.flags.NonTxFlagsEnabledTest

org.infinispan.api.mvcc.PutForExternalReadLockCleanupTest

org.infinispan.api.mvcc.PutForExternalReadTest

org.infinispan.api.RepeatableReadRemoteGetCountTest

org.infinispan.api.ReplicatedNonTxCacheTest

org.infinispan.atomic.AtomicMapStateTransferTest

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.