hi,
Question about geode streaming. I have a client proxy region local created
this way.
ClientCacheFactory cacheFactory = new ClientCacheFactory();
cacheFactory.addPoolLocator(xxx,yyy);
cacheFactory.setPoolMinConnections(4)
.setPoolSubscriptionEnabled(true)
.setPoolThreadLocalConnections((Boolean)GeodeConfig.getInstance().getConfig().get("pool-threadlocal-connection"));
ClientCache clientCache = cacheFactory.create();
ClientRegionFactory<String, byte[]> regionFactory =
clientCache.createClientRegionFactory(ClientRegionShortcut.PROXY);
region =
regionFactory.addCacheListener(cacheListener).create("rep_region");
and my listerner.
public class SimpleCacheListener extends CacheListenerAdapter {
@Override
public void afterUpdate(EntryEvent event) {
processor.addEvent(event);
}
}
When I use this region put and listener at different JVM, everything works
fine. The afterUpdate get triggered, but when I use the same region but pub
and sub at one JVM (different thread), the callback not get triggered at all.
Is there a setting for it? and reasoning for this?
Thanks,
Nan
----------------------------------------------------------------------
This message, and any attachments, is for the intended recipient(s) only, may
contain information that is privileged, confidential and/or proprietary and
subject to important terms and conditions available at
http://www.bankofamerica.com/emaildisclaimer. If you are not the intended
recipient, please delete this message.