Upgrade to Reactor 1.1

Fixes gh-706
This commit is contained in:
Dave Syer
2014-04-30 11:26:57 +01:00
parent a27be338c6
commit f46d281b22
4 changed files with 32 additions and 11 deletions

View File

@@ -3,6 +3,7 @@ package org.test
import java.util.concurrent.CountDownLatch;
@EnableReactor
@Consumer
@Log
class Runner implements CommandLineRunner {
@@ -22,7 +23,7 @@ class Runner implements CommandLineRunner {
latch.await()
}
@Selector(reactor="reactor", value="hello")
@Selector(value="hello")
void receive(String data) {
log.info "Hello ${data}"
latch.countDown()