Re: Trouble with continuous queries

2019-05-30 Thread Alexandr Shapkin
Wait a sec, I have already posted an example, but for some reasons it was not send properly. Here are we go: class Program { private static IContinuousQueryHandle _continuousQuery; const string CacheName = "sample"; const string TableName = "entity"; static void Main(string[]

Re: Trouble with continuous queries

2019-05-30 Thread Mike Needham
My next hurdle is to get a remote listener from .NET working to the cache On Thu, May 30, 2019 at 1:47 PM Mike Needham wrote: > I was able to figure this out. Was missing > the ignite.events().localListen(lsnr, EVT_CACHE_OBJECT_PUT); > > On Thu, May 30, 2019 at 12:43 PM Mike Needham wrote: >

Re: Trouble with continuous queries

2019-05-30 Thread Mike Needham
I was able to figure this out. Was missing the ignite.events().localListen(lsnr, EVT_CACHE_OBJECT_PUT); On Thu, May 30, 2019 at 12:43 PM Mike Needham wrote: > But does ignite fire the ignite > event EventType.EVT_CACHE_OBJECT_PUT, EventType.EVT_CACHE_OBJECT_READ > and

Re: Trouble with continuous queries

2019-05-30 Thread Mike Needham
But does ignite fire the ignite event EventType.EVT_CACHE_OBJECT_PUT, EventType.EVT_CACHE_OBJECT_READ and EventType.EVT_CACHE_OBJECT_REMOVED On Thu, May 30, 2019 at 12:18 PM Alexandr Shapkin wrote: > Hi, yes, it should work that way. > > I was able to caught all events event with the raw SQL

Re: Trouble with continuous queries

2019-05-30 Thread Alexandr Shapkin
Hi, yes, it should work that way. I was able to caught all events event with the raw SQL using this DBeaver https://apacheignite-sql.readme.io/docs/sql-tooling -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Trouble with continuous queries

2019-05-30 Thread Mike Needham
Do cache events fire when using SQL to update tables? My app is listening to a queue for json payloads that have the INS/UPD/DEL: for the cache entries. They are updated using SQL over the respective caches. On Wed, May 29, 2019 at 8:14 AM Mike Needham wrote: > I have tried various things,

Re: Trouble with continuous queries

2019-05-29 Thread Mike Needham
I have tried various things, but it never fires for a change in the cache. that is why I do not think it is set-up correctly On Tue, May 28, 2019 at 9:30 AM Alexandr Shapkin wrote: > Hi, > > You can just save an instance of continuous query somewhere and dispose it > when required > > > var

Re: Trouble with continuous queries

2019-05-28 Thread Alexandr Shapkin
Hi, You can just save an instance of continuous query somewhere and dispose it when required var listener = new SomeListener(); var someFilter= new CacheEntryEventFilter(_ignite.GetCluster().GetLocalNode(), Const.CacheName); var query = new ContinuousQuery(listener, someFilter);

Re: Trouble with continuous queries

2019-05-22 Thread Mike Needham
private const string CacheName = "EXCHANGE"; static void Main(string[] args) { using (var ignite = Ignition.Start("E:\\ignite\\apache-ignite-2.7.0-src\\examples\\config\\example-igniteClient.xml")) { { var cacheCfg = new

Re: Trouble with continuous queries

2019-05-22 Thread Denis Mekhanikov
Mike, Could you show the code, that you use to register the continuous query? Maybe there is some misconfiguration? Denis пн, 20 мая 2019 г. в 17:47, Mike Needham : > Hi All, > > I have a cache that is running and is defined as > IgniteCache exchCache = >

Re: Trouble with continuous queries

2019-05-20 Thread Mike Needham
Hi All, I have a cache that is running and is defined as IgniteCache exchCache = ignite.getOrCreateCache(new CacheConfiguration<>("EXCHANGE") .setIndexedTypes(Long.class, Exchange.class) .setAtomicityMode(CacheAtomicityMode.ATOMIC) .setBackups(0)

Re: Trouble with continuous queries

2019-05-14 Thread Denis Mekhanikov
Mike, First of all, it's recommended to have a separate cache per table to avoid storing of objects of different types in the same cache. Continuous query receives all updates on the cache regardless of their type. Local listener is invoked when new events happen. Existing records can be

Re: Trouble with continuous queries

2019-05-02 Thread Mike Needham
I have seen that example, what I do not understand is I have two SQL tables in a cache that has n number of nodes. it is loaded ahead of time and a client wants to be notified when the contents of the cache are changed. Do you have to have the continuous query in a never ending loop to not have

Re: Trouble with continuous queries

2019-05-02 Thread aealexsandrov
Hi, The good example of how it can be done you can see here: https://github.com/gridgain/gridgain-advanced-examples/blob/master/src/main/java/org/gridgain/examples/datagrid/query/ContinuousQueryExample.java You can set remote listener to handle changes on remote nodes and local listers for

Trouble with continuous queries

2019-05-01 Thread Mike Needham
Hi All, I have a setup that is creating a cache with two SQL tables in it. I am able to update the cache and now want to have a client use the continuous queries to be notified of any changes to the cache. the cache is using the default config and has the cache defined as IgniteCache testCache