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[]
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:
>
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
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
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/
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,
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
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);
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
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 =
>
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)
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
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
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
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
15 matches
Mail list logo