28.5. Key Affinity Service

Procedure 28.3. Using the Key Affinity Service

1. Obtain a reference to a cache manager and cache

   EmbeddedCacheManager cacheManager = getCacheManager();
   Cache cache = cacheManager.getCache();

2. Create the affinity service

   This starts the service, then uses the supplied Executor to generate and queue keys.

   KeyAffinityService keyAffinityService = 
           KeyAffinityServiceFactory.newLocalKeyAffinityService(
               cache,
               new RndKeyGenerator(),
               Executors.newSingleThreadExecutor(),
               100);

3. Obtain a key to be mapped to a certain address

   Obtain a key from the service which will be mapped to the local node (cacheManager.getAddress() returns the local address).

   Object localKey = keyAffinityService.getKeyForAddress(cacheManager.getAddress());

4. Put the value on the node

   The entry with a key obtained from the KeyAffinityService is always stored on the node with the provided address. In this case, it is the local node.

   cache.put(localKey, "yourValue");