How to get the primary cache adress of one key value in 5.1.0.final?

[nkzhangni]

Hi all,

The code is as following.

When I enforce these codes, the aa always is null, and can not get the value of aa.primaryLocation("key");

Is there are any configuration I should do?

new DefaultCacheManager(

                GlobalConfigurationBuilder.defaultClusteredBuilder()

                      .transport().addProperty("configurationFile", "jgroups.xml")

                      .build(),  

            new ConfigurationBuilder()

                  .clustering()

                     .cacheMode(CacheMode.DIST_SYNC)

                     .hash().numOwners(2)

                  .build()

      );

	HashConfiguration bb = cache.getCacheConfiguration().clustering().hash();
	System.out.print("bb\n");
	if(bb!=null)
	{
		System.out.print("bb no null\n");
	ConsistentHash aa = bb.consistentHash();
	System.out.print("aa\n");
	if(aa!=null)
	{
		System.out.print("aa no null\n");
		Address cc = aa.primaryLocation("key");
		String str =cc.toString();
	System.out.print(str);
	}
	}

[galder.zamarreno]

Use cache.getAdvancedCache().getDistributionManager().getPrimaryLocation(key)

https://github.com/galderz/infinispan/blob/master/core/src/main/java/org/infinispan/distribution/DistributionManager.java#L83

[dan.berindei]

Just to make it clear: even if you configure a ConsistentHash, we only use the ConsistentHash instance from the configuration as a template. Every time the membership of the cache changes, we create a new ConsistentHash object.

You can use the methods in DistributionManager to access the current ConsistentHash, either explicitly or via helper methods like getPrimaryLocation(key).