Re: Event Listners when we use DataStreamer

2020-05-01 Thread Ilya Kasnacheev
Hello! We have a test for this in our code base, org.apache.ignite.internal.processors.datastreamer.DataStreamProcessorSelfTest#testFlushTimeout It passes in 2.8. Do you have a reproducer where you don't see EVT_CACHE_OBJECT_PUT for cache populated by data streamer with allowOverride(true)? Can

Re: Event Listners when we use DataStreamer

2020-05-01 Thread krkumar24061...@gmail.com
Hi Ilya - I have tried that but not firing the event. But it does fire for put and putAll Thanx and Regards, KR Kumar -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Event Listners when we use DataStreamer

2020-04-30 Thread Ilya Kasnacheev
Hello! Does this change if you set allowOverride(true) on Data Streamer? Regards, -- Ilya Kasnacheev чт, 30 апр. 2020 г. в 16:29, krkumar24061...@gmail.com < krkumar24061...@gmail.com>: > Hi Guys - When I am adding entries into cache through DataStreamer.addData, > does it invoke the event

Event Listners when we use DataStreamer

2020-04-30 Thread krkumar24061...@gmail.com
Hi Guys - When I am adding entries into cache through DataStreamer.addData, does it invoke the event listeners configured for EVT_CACHE_ENTRY_CREATED, EventType.EVT_CACHE_OBJECT_PUT?? I am configuring a local listener in the following way engine.events().localListen(cacheChangeHandler,