Hi there.I found that for Ignite V 1.5.6 and 1.5.7 Continuous query stop
working while it worked for V1.5.3.My code follows the manual:// Create new
continuous query.ContinuousQuery<K,V> query = new ContinuousQuery<K,V>();
query.setInitialQuery(sql); query.setRemoteFilter(new
CacheEntryEventSerializableFilter<K,V>() { public boolean
evaluate(CacheEntryEvent<? extends K, ? extends V> event) throws... {
return satisfyCondition(event.getValue()); }
});
query.setLocalListener(new CacheEntryUpdatedListener<K,V>() { public
void
onUpdated(Iterable<CacheEntryEvent<? extends K, ? extends V>>
itrEvent)...{
// received the value - done };
});
QueryCursor<javax.cache.Cache.Entry<K,V>> items =
(QueryCursor<Entry<K, V>>) cache.query(query); if (items != null) {
.... }The same code (like above) runs in V1.5.3 propagating from the
Remote filter to the Local listener (when the condition returns TRUE) and
with 1.5.6 onward the listener is not invoked though the filter receives the
notification and return TRUE.If this is not due to the intended changes in
how the CQ gets handled, this must be a bug in the corresponding
versions.Many thanks,Alex
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Continuous-Query-tp3383.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
