Re: using dataStreamer inside Ignite service grid execute

2017-10-24 Thread slava.koptilin
Hello, > is there a way to pass the same streamer to execute function? I don't think so. The obvious solution is creating a data streamer inside the service implementation and using it for populating data/executing stream visitor logic. Thanks. -- Sent from: http://apache-ignite-users.70518.x

Re: using dataStreamer inside Ignite service grid execute

2017-10-20 Thread shuangjiang.li
I see the reason now, is there a way to pass the same streamer to execute function? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: using dataStreamer inside Ignite service grid execute

2017-10-20 Thread slava.koptilin
Hi, Ignie#dataStreamer(String cacheName) method creates a new instance of data streamer. So, you created two different instances of data streamer that are not communicating in any way each other. That is the reason, why there is no output inside the service grid function. Thanks! -- Sent from:

using dataStreamer inside Ignite service grid execute

2017-10-19 Thread shuangjiang.li
Hi, I am trying to implement StreamVisitor function inside service grid execute function.I started ignite node and service deployment in the main function, however, in the execute logic, there is no output message print out. I tested the logic can be triggered when the StreamVisitor code is put alo