Rough agenda follows:

Similarities

• wrap business methods, laziness

• custom thread pool
• parallelize PersonDao and WeatherClient with zipWith()

• CacheServer x2

• Polling for file system changes
• Potential memory leak, RxJava 2.0, distinctUntilChanged()

• timeout(), retry(), doOnError()
• assertNoValues(), assertNoErrors()

CamelContext camel = new DefaultCamelContext();
ReactiveCamel reactiveCamel = new ReactiveCamel(camel);
reactiveCamel
		.toObservable("activemq:queue:rx-queue")
		.map(Message::getBody)
		.toBlocking()
		.subscribe(e ->
				log.info("Message: {}", e));

• Parallel fetching of URLs

• Pinger, sliding window of Status instances