[James Dodson <ji...@gmail.com>]

Hello.

I am creating a Spring Boot application that gets objects from Kinesis and
uses ignite-spring-data to insert those objects into an Ignite cluster.

As objects are inserted, I want to take some action - specifically, inspect
the object being inserted, query Ignite for a related object and if not
found, send a message to Kinesis.

It seems I could possibly use CacheStoreAdapter, a continuous query, or a
cache event listener.

I'm wondering which of these (or something else?) is suggested for this use
case?

Thanks!

Re:

[Вячеслав Коптилин <sl...@gmail.com>]

Hello,

I think ContinuousQuery will be a good choice for your use-case [1]

[1] https://apacheignite.readme.io/docs/continuous-queries

Thanks!

ср, 27 июн. 2018 г. в 18:51, James Dodson <ji...@gmail.com>:

> Hello.
>
> I am creating a Spring Boot application that gets objects from Kinesis and
> uses ignite-spring-data to insert those objects into an Ignite cluster.
>
> As objects are inserted, I want to take some action - specifically,
> inspect the object being inserted, query Ignite for a related object and if
> not found, send a message to Kinesis.
>
> It seems I could possibly use CacheStoreAdapter, a continuous query, or a
> cache event listener.
>
> I'm wondering which of these (or something else?) is suggested for this
> use case?
>
> Thanks!
>