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();
}