Hi!

I need a way to consistently get all entries in a replicated cache and then all updates for them while application is working.

I use ContinuousQuery for it.

var cursor = cache.QueryContinuous(new ContinuousQuery<string, byte[]>(new CacheListener(), true),
                new ScanQuery<string, byte[]>()).GetInitialQueryCursor();

But I have some issues with it.

Sometimes cursor returns only part of entries in a cache and cache listener does not return them either.

Sometimes cursor and cache listener return the same entry both.

Issue somehow related to amount of work the nodes have to do and amount of time between start of the publisher node and subscriber node.

There are more problems if nodes start at the same time.

Is there a reliable way to do it without controling order of node start and pauses between them?


Reply via email to