Main.java

package com.some.company.project.name;

import com.gemstone.gemfire.cache.InterestResultPolicy;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.client.ClientCache;
import com.gemstone.gemfire.cache.client.ClientCacheFactory;
import com.gemstone.gemfire.cache.client.ClientRegionShortcut;
import com.gemstone.gemfire.cache.client.PoolManager;
import com.gemstone.gemfire.internal.cache.InternalCache;

import java.util.Arrays;

public class Main {
    private static final String TEST_REGION = "server-existing-region";
    private static final String POOL_NAME = "gemfirePool";

    public static void main(String []args) {
        System.out.println("Connecting...");

        ClientCache cache = new ClientCacheFactory().
                        addPoolLocator("gemfire01", 10334).
                        addPoolLocator("gemfire02", 10334).
                        addPoolLocator("gemfire03", 10334).
                        addPoolLocator("gemfire04", 10334).
                        addPoolLocator("gemfire05", 10334).
                        addPoolLocator("gemfire06", 10334).
                        //addPoolServer("gemfire01", 40404).
                        setPoolSubscriptionEnabled(true).
                        setPoolMinConnections(20).
                        setPoolFreeConnectionTimeout(20000).
                        setPoolIdleTimeout(20000).
                        setPoolPingInterval(5000).
                        setPoolReadTimeout(60000).
                        set("log-level", "warning").
                        //set("version", "8.1").
                        setPdxPersistent(false).
                        //setPdxSerializer(new ReflectionBasedAutoSerializer("java.util.*,java.lang.*")).
                        setPoolPRSingleHopEnabled(true).
                        //set("cache-xml-file", "//home/user/.../client-cache.xml").
                        create();
        //PoolManager.getAll().entrySet()
        /*PoolManager.createFactory().
                        addLocator("gemfire01", 10334).
                        addLocator("gemfire02", 10334).
                        addLocator("gemfire03", 10334).
                        addLocator("gemfire04", 10334).
                        addLocator("gemfire05", 10334).
                        addLocator("gemfire06", 10334).
                        setSubscriptionEnabled(true).
                        setMinConnections(20).
                        setFreeConnectionTimeout(20000).
                        setIdleTimeout(20000).
                        setPingInterval(5000).
                        setReadTimeout(60000).
                        setPRSingleHopEnabled(true).
                        create(POOL_NAME);*/
        //PoolManager.getAll()
        //cache.getCacheTransactionManager().begin().commit();
        //CacheClientUpdater -> ConnectionFactoryImpl.createServerToClientConnection
        cache.setCopyOnRead(true);
        //cache.readyForEvents();
        //CacheFactory.getAnyInstance();
        System.out.println("Members...");
        ((InternalCache) cache).getMembers().forEach(member ->
            System.out.format("> %s. %s = %s\n", member.getProcessId(), member.getName(), member.getHost())
        );
        System.out.println("Admin members...");
        ((InternalCache) cache).getAdminMembers().forEach(member ->
                        System.out.format("> %s. %s = %s\n", member.getProcessId(), member.getName(), member.getHost())
        );
        System.out.println("Servers...");
        cache.getCurrentServers().forEach(server ->
            System.out.format("> %s:%d\n", server.getHostString(), server.getPort())
        );
        System.out.println("Root regions...");
        cache.rootRegions().forEach(region ->
            System.out.format("> %s\n", region.getName())
        );
        Region<Object, Object> rootRegion = cache.getRegion(TEST_REGION);
        if (rootRegion == null) {
            System.out.println("No root region!");
        } else {
            System.out.println("Listing root...");
            rootRegion.entrySet().forEach(entry ->
                System.out.format("%s = %s\n", entry.getKey(), entry.getValue())
            );
        }
        //new GemFireCache().getQueryService()
        //cache.getQueryService()
        //RegionShortcut.REPLICATE_PROXY <- server!
        //DataPolicy = NORMAL
        //new AttributesFactory().setDataPolicy(DataPolicy.NORMAL);
    //ClientRegionShortcut.PROXY
        Region<Object, Object> region = cache.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY)
                        //.addCacheListener(new SubscriberListener())
                        //.addCacheListener(new CacheClientUpdater())
                        //.setPoolName(POOL_NAME)
                        .create(TEST_REGION);
        /*RegionAttributesCreation attributes = new RegionAttributesCreation(new CacheCreation());
        attributes.setDataPolicy(DataPolicy.NORMAL);
        cache.setRegionAttributes("PROXY", attributes);*/
        //cache.getRegionAttributes("PROXY").getScope();
        //cache.setRegionAttributes("PROXY", Scope.GLOBAL);
        //region.registerInterest("ALL_KEYS", InterestResultPolicy.KEYS);
        region.registerInterest(".*", InterestResultPolicy.NONE, false);
        System.out.println("Attributes");
        System.out.format("> DataPolicy: %s\n> Scope: %s\n", region.getAttributes().getDataPolicy(), region.getAttributes().getScope());
        Arrays.asList(region.getAttributes().getCacheListeners()).forEach(listener ->
            System.out.format("> %s\n", listener.getClass().getCanonicalName())
        );
        System.out.println("Listing...");
        region.entrySet().forEach(entry ->
            System.out.format("%s = %s\n", entry.getKey(), entry.getValue())
        );
        System.out.println("Done!");
        System.exit(0);
    }
}
//java -Xdebug -Xrunjdwp:transport=dt_socket,address=5005,server=y,suspend=y -jar app.jar