Reactor hangs

gistfile1.java

Environment env = new Environment();

Reactor reactor = Reactors.reactor()
        .env(env)
        .dispatcher(Environment.THREAD_POOL)
        .get();


reactor.on(Selectors.$("worker"), new Consumer() {
    @Override
    void accept(Object o) {
        println Thread.currentThread().getName() + " worker " + o
        reactor.notify("orchestrator", Event.wrap("ok"))
        println Thread.currentThread().getName() + " ok"
    }
})

reactor.on(Selectors.$("orchestrator"), new Consumer<Event>() {

    AtomicInteger tasksCount;

    @Override
    void accept(Event event) {
        if (event.getData() instanceof Integer) {
            tasksCount = new AtomicInteger(event.getData())
        }
        sendTask()
    }

    void sendTask() {
        println Thread.currentThread().getName() + " sendTask ";
        reactor.notify("worker", Event.wrap(tasksCount.decrementAndGet()))
    }
})


reactor.notify("orchestrator", Event.wrap(1000))