ping_pong_test.java

	@Test
	public void workerOrchestrator() throws InterruptedException {
		Environment env = new Environment();

		Reactor reactor = Reactors.reactor(env, Environment.THREAD_POOL);

		CountDownLatch latch = new CountDownLatch(2);

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

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

			@Override
			public void accept(Event<Integer> event) {
				sendTask();
			}

			void sendTask() {
				System.out.println(Thread.currentThread().getName() + " sendTask ");
				reactor.notify("worker", Event.wrap(latch.getCount()));
				latch.countDown();
			}
		});

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

		latch.await(5, TimeUnit.SECONDS);
	}