public static void main()

in async/src/main/java/org/apache/geode_examples/async/Example.java [31:54]


  public static void main(String[] args) {
    // connect to the locator using default port 10334
    ClientCache cache = new ClientCacheFactory().set("log-level", "WARN").create();

    final String poolName = "subscriptionPool";
    PoolManager.createFactory().addLocator("127.0.0.1", 10334).setSubscriptionEnabled(true)
        .create(poolName);

    // create a local region that matches the server region
    final ClientRegionFactory<Integer, String> incomingRegionFactory =
        cache.<Integer, String>createClientRegionFactory(ClientRegionShortcut.PROXY);
    Region<Integer, String> incomingRegion =
        incomingRegionFactory.setPoolName(poolName).create(INCOMING_REGION_NAME);

    // create another local region that matches the server region
    final ClientRegionFactory<String, String> outgoingRegionFactory =
        cache.<String, String>createClientRegionFactory(ClientRegionShortcut.PROXY);
    Region<String, String> outgoingRegion =
        outgoingRegionFactory.setPoolName(poolName).create(OUTGOING_REGION_NAME);

    new Example().checkWords(incomingRegion, outgoingRegion,
        Arrays.asList(new String[] {"that", "teh", "wil", "i'"}));
    cache.close();
  }