Hello, Nikolay. I think we can't use this method:
We need to set: * transformer * *local listener* - differs from regular ContinuousQuery listener * other continuous query params. So at least we have to add local listener param. If we use ContinuousQuery instance as first param to get all ContinuousQuery params: timeout, pageSize, filter, etc... then we have to ignore local listener inside it. What do you think? 2017-09-05 15:48 GMT+03:00 Nikolai Tikhonov <ntikho...@apache.org>: > Guys, > > This API looks very complicated. We already have similar functionality for > ScanQuery, let's reuse it. Please, have a look > at IgniteCache#query(org.apache.ignite.cache.query.Query<T>, > org.apache.ignite.lang.IgniteClosure<T,R>) method. It looks more pretty > for > me. Any objections? > > Thanks, > Nikolay > > On Mon, Sep 4, 2017 at 3:22 PM, Николай Ижиков <nizhikov....@gmail.com> > wrote: > > > Yakov, Anton, thank you! > > > > 2017-09-04 15:16 GMT+03:00 Yakov Zhdanov <yzhda...@apache.org>: > > > > > Well, let's leave it as is for now, since I don't see any easy way to > > > consistently solve this. > > > > > > --Yakov > > > > > > > > > > > -- > > Nikolay Izhikov > > nizhikov....@gmail.com > > > -- Nikolay Izhikov nizhikov....@gmail.com
