Import as gradle project using java 1.8

Make sure your intellij Java level set to 8 - Lambdas (required for lambdas to work)

Example 1 : Simple Observable on interval

SimpleIntervalServer run main()

Example 2 : Stock Observable and Flowable

StockServerExample run main()

Example 3: Full fledged example of a event based reactive architecture running on cluster passing msg between 3 different services

SockJsServer run main() Appointment run main() Inventory run main () (Order not important . Beauty of async messaging)

open index.html in browser to see the msgs