Re: IgniteDataStreamer with Continuous Query

[Denis Magda]

Hi,

You need to put the continuous query execution statement out of the
try-with-resource block. So, the code has to look like this

                QueryCursor<Cache.Entry&lt;String, Integer>> cur =
stmCache.query(continuousQuery);

                for(Cache.Entry<String,Integer> c : cur) {
                    System.out.println(c);
                }

Presently, your continuous query is automatically closed right after the
initial result is received. This is triggered by try-with-resource block.

--
Denis



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/IgniteDataStreamer-with-Continuous-Query-tp9779p9810.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.