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 <jimdod...@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! >
