It is likely entries are being quickly produced and filling up the buffer
giving the effect of an immediate update.
You can test it via specific delays and logging.
Make the server print out the counter of the object.
say:
if the key is an integer and the value is too then print out the key as
you put it in.
do the same on the client when it receives the object.
Produce a number less than the buffer size , put in a 10 second delay, see
what the client gives then produce more items, and again observe the client.
You can also set pageSize to a very large number -- say 40000 and watch it
update in intervals. -- be aware that here memory effects might come into
play especially if your objects are large.
Here is an example:
the server will produce 100 then sleep.
the client has set the pageCount to 1000
for every 10 "sleeping.." it will print out the 1000 entries.
*server:*
int i = 0;
int sleepCounter = 1;
while (true) {
cache.put(i++, Integer.toString(i));
System.out.println("added entry: " + i);
if(i%100 == 0){
System.out.println("sleeping: " + sleepCounter++);
if(sleepCounter %10 == 0) sleepCounter = 0;
Thread.sleep(1000);
}
}
*client: *
ContinuousQuery < Integer, String > qry = new ContinuousQuery<>();
qry.setTimeInterval(0);
qry.setPageSize(1000);
qry.setLocalListener((evts) -> evts.forEach(e ->
System.out.println("key=" + e.getKey() + ", val=" + e.getValue())));
cache.query(qry);
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
