On Sat, Oct 3, 2015 at 7:52 PM, pitabwire <[email protected]> wrote: > While developing an MQTT broker <https://github.com/caricah/iotracah> > based on apache Ignite. I would really like to leverage ignite's compute > grid via the ExecutorService api however the challenge currently is > observables are not getting executed if I use Ignite's ExecutorService, > however if I switch to RxJava's Schedulers.io() or any defaults things just > work. >
Are you using the latest version of Ignite (1.4)? Ignite ExecutorService should work with all defaults. Does this example, which comes with Ignite, work for you? https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteExecutorServiceExample.java The only reason I can see for this example not working is if the nodes do not discover each other. Can you confirm that discovery happens (look for topology snapshot print out in the log)? Are there any other errors in the log? D. > > Any pointers in the right direction are highly appreciated, or if there is > already a known/particular way to use ignite with RxJava, that would go a > long way too. > > > > -- > View this message in context: > http://apache-ignite-users.70518.x6.nabble.com/Ignite-executor-does-not-working-with-RxJava-as-a-scheduler-tp1543.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. >
